Ошибка с Flink-Gelly, lastJobExecutionResult имеет значение null для ExecutionEnvironment - PullRequest
Новая
       25

Ошибка с Flink-Gelly, lastJobExecutionResult имеет значение null для ExecutionEnvironment

0 голосов
/ 02 августа 2020

Я пытаюсь использовать Flink-Gelly. Я использовал версию Flink 1.11 (я также пробовал 1.12, она тоже не работает).

Следуя инструкциям в Обзор Flink Gelly . Сначала я создаю свой код Flink с помощью:

(1) git clone https://github.com/apache/flink.git

(2) mvn package –DskipTests

Затем я копирую некоторую библиотеку Gelly в каталог библиотеки Flink.

(3) cp opt/flink-gelly_2.11-1.11-SNAPSHOT.jar lib/ Далее я запускаю кластер в автономном режиме

(4) ./bin/start-cluster.sh

Кстати, вся конфигурация Flink в «flink -conf.yaml »установлен по умолчанию. Наконец, я запускаю код из Gelly и получаю сообщение об ошибке.

(5) Выполните следующую команду 

./bin/flink run examples/gelly/flink-gelly-examples_2.11-1.11-SNAPSHOT.jar \
--algorithm GraphMetrics --order directed \
--input RMatGraph --type integer --scale 20 --simplify directed \
--output print

Это сообщение об ошибке: 

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: No result found for job, was execute() called before getting the result?
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)
        at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149)
        at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699)
        at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232)
        at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916)
        at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992)
        at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
        at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992)
Caused by: java.lang.NullPointerException: No result found for job, was execute() called before getting the result?
        at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
        at org.apache.flink.graph.AnalyticHelper.getAccumulator(AnalyticHelper.java:81)
        at org.apache.flink.graph.library.metric.directed.VertexMetrics.getResult(VertexMetrics.java:116)
        at org.apache.flink.graph.library.metric.directed.VertexMetrics.getResult(VertexMetrics.java:56)
        at org.apache.flink.graph.drivers.GraphMetrics.printAnalytics(GraphMetrics.java:113)
        at org.apache.flink.graph.Runner.execute(Runner.java:458)
        at org.apache.flink.graph.Runner.main(Runner.java:507)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:288)
        ... 8 more

Я проверил журнал диспетчера заданий и диспетчера задач, и об ошибках не сообщается.

Кажется, ошибка подразумевает, что «lastJobExecutionResult» в «ExecutionEnvironment» имеет значение null. Но я уже отправил задание, и оно выполняется.

Не могли бы вы поделиться некоторыми идеями о моей проблеме?

Большое спасибо.

...