Java hadoop api YarnClient не имеет функции "init () / start ()"? - PullRequest
0 голосов
/ 10 декабря 2018

Я попробовал репозиторий Maven следующим образом:

    <dependency>
        <groupId>org.apache.hadoop</groupId>
        <artifactId>hadoop-yarn-common</artifactId>
        <version>2.7.2</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-yarn-api -->
    <dependency>
        <groupId>org.apache.hadoop</groupId>
        <artifactId>hadoop-yarn-api</artifactId>
        <version>2.7.2</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-yarn-client -->
    <dependency>
        <groupId>org.apache.hadoop</groupId>
        <artifactId>hadoop-yarn-client</artifactId>
        <version>2.7.2</version>
    </dependency>

Тогда мой код Java:

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.yarn.api.ApplicationConstants;
import org.apache.hadoop.yarn.api.records.*;
import org.apache.hadoop.yarn.client.api.YarnClient;
import org.apache.hadoop.yarn.client.api.YarnClientApplication;
import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.apache.hadoop.yarn.exceptions.YarnException;

public static void main(String[] args) {
    YarnConfiguration yarnConfiguration = new YarnConfiguration();
    YarnClient yarnClient = YarnClient.createYarnClient();
    yarnClient.init(yarnConfiguration);
    yarnClient.start();
}

Intellij ide показывает «Не удается решить метод init» и «Не удается решить запуск метода».

Затем я попытался использовать версию jar 3.1.1 вместо «2.7.2».Тот же результат.Так что не так с моим кодом и как это исправить?

1 Ответ

0 голосов
/ 17 марта 2019

метод init и start являются производными от класса AbstractService.вам нужно убедиться, что YarnClient и AbstractService имеют одинаковую версию.

перейдите в YarnClient и проверьте jar, к которому он относится, затем щелкните по родительскому объекту AbstractService из клиента Yarn и проверьте его версию.

измените версию YarnClient в соответствии с вашей версией AbstractService.

У меня была такая же проблема, она работает для меня.версия 2.6.5.

...