(DEPRECATED) Apache Flink User Mailing List archive.

Error with Flink-Gelly, lastJobExecutionResult is null for ExecutionEnvironment

Classic

List

Threaded

2 messages Options

Xia Rui

Error with Flink-Gelly, lastJobExecutionResult is null for ExecutionEnvironment

Hello, everyone.

I am trying to use Flink-Gelly. The version of Flink I used is 1.11 (I also tried 1.12, and it does not work as well).

Following the instruction in https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/libs/gelly/ .

First, I build my Flink code with:

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

(2) mvn package –DskipTests

Then, I copy some Gelly lib to Flink’s lib directory

(3) cp opt/flink-gelly_2.11-1.11-SNAPSHOT.jar lib/

Next, I start the cluster with standalone mode

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

By the way, all the Flink configuration in “flink-conf.yaml” is set as default.

Finally, I run the code from Gelly, and get Error.

(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

This is the error message:

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

I have checked the log of jobmanager and taskmanager, and no error is reported.

The error seems to imply that the ‘lastJobExecutionResult’ in ‘ExecutionEnvironment’ is null. But I have already submit the job, and it is running.

Could you share me some idea about my problem?

Thank you very much.

Rui Xia

Till Rohrmann

Re: Error with Flink-Gelly, lastJobExecutionResult is null for ExecutionEnvironment

The discussion is held on the dev mailing list: https://lists.apache.org/thread.html/rfed34be1651aa15fbdd0b3cac0d5607fa34886c1cf1aacf06684e995%40%3Cdev.flink.apache.org%3E.

Cheers,

Till

On Sat, Aug 1, 2020 at 8:16 AM Xia Rui <[hidden email]> wrote:

Hello, everyone.
I am trying to use Flink-Gelly. The version of Flink I used is 1.11 (I also tried 1.12, and it does not work as well).

Following the instruction in https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/libs/gelly/ .
First, I build my Flink code with:
(1)   git clone https://github.com/apache/flink.git
(2)   mvn package –DskipTests
Then, I copy some Gelly lib to Flink’s lib directory
(3)   cp opt/flink-gelly_2.11-1.11-SNAPSHOT.jar lib/
Next, I start the cluster with standalone mode
(4)   ./bin/start-cluster.sh
By the way, all the Flink configuration in “flink-conf.yaml” is set as default.
Finally, I run the code from Gelly, and get Error.
(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
This is the error message:

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

I have checked the log of jobmanager and taskmanager, and no error is reported.

The error seems to imply that the ‘lastJobExecutionResult’ in ‘ExecutionEnvironment’ is null. But I have already submit the job, and it is running.

Could you share me some idea about my problem?

Thank you very much.
Rui Xia