You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Shiyu Jin (Jira)" <ji...@apache.org> on 2020/09/15 14:52:00 UTC
[jira] [Created] (FLINK-19248) The main method caused an error: No
result found for job, was execute() called before getting the result
Shiyu Jin created FLINK-19248:
---------------------------------
Summary: The main method caused an error: No result found for job, was execute() called before getting the result
Key: FLINK-19248
URL: https://issues.apache.org/jira/browse/FLINK-19248
Project: Flink
Issue Type: Bug
Components: Library / Graph Processing (Gelly)
Affects Versions: 1.11.1
Reporter: Shiyu Jin
*[_Gelly_]* *The main method caused an error: No result found for job, was execute() called before getting the result?*
I download [flink-1.11.1-bin-scala_2.12.tgz|http://apache.mirrors.pair.com/flink/flink-1.11.1/flink-1.11.1-bin-scala_2.12.tgz] from the official site of flink, then do as
[Running Gelly Examples|https://ci.apa%20che.org/projects/flink/flink-docs-release-1.11/dev/libs/gelly/#running-gelly-examples] says to try the pagerank algorithm and hit the problem above, the details are shown as below (you can reproduce the error if you follow the steps)
{code:bash}
[corona@cas dist ]$ tar -xf flink-1.11.1-bin-scala_2.12.tgz
[corona@cas dist ]$ cd flink-1.11.1
[corona@cas flink-1.11.1]$ cp -v opt/flink-gelly*.jar lib # it copies two gelly jars
'opt/flink-gelly_2.12-1.11.1.jar' -> 'lib/flink-gelly_2.12-1.11.1.jar'
'opt/flink-gelly-scala_2.12-1.11.1.jar' -> 'lib/flink-gelly-scala_2.12-1.11.1.jar'
[corona@cas flink-1.11.1]$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host cas.
Starting taskexecutor daemon on host cas.
[corona@cas flink-1.11.1]$ ./bin/flink run examples/gelly/flink-gelly-examples_2.12-1.11.1.jar --algorithm PageRank --input StarGraph --vertex_count 5 --output Print
Job has been submitted with JobID f867abf1d2cd94d07a419591e41b63a5
Program execution finished
Job with JobID f867abf1d2cd94d07a419591e41b63a5 has finished.
Job Runtime: 1647 ms
Accumulator Results:
- 6907b5f63ee1f31af9715772ddcff154-collect (java.util.ArrayList) [5 elements]
# ERROR messages show up
------------------------------------------------------------
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.asm.dataset.Collect.getResult(Collect.java:62)
at org.apache.flink.graph.asm.dataset.Collect.getResult(Collect.java:35)
at org.apache.flink.graph.asm.dataset.DataSetAnalyticBase.execute(DataSetAnalyticBase.java:56)
at org.apache.flink.graph.drivers.output.Print.write(Print.java:48)
at org.apache.flink.graph.Runner.execute(Runner.java:454)
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
{code}
I build flink from source code(master branch, latest code, 2020-09-14, e594cf541f2f877b91196e8a9cf63caa5664d71d) as below and fail again(same error message)
{code:bash}
[corona@cas github]$ git clone https://github.com/apache/flink.git
[corona@cas github]$ cd flink/
[corona@cas flink]$ mvn clean package -DskipTests -Drat.skip=true
... a lot of output
C[corona@cas flink]$ cd build-target
[corona@cas build-target]$ ls
bin conf examples lib LICENSE log opt plugins README.txt
[corona@cas build-target]$ cp -v opt/flink-gelly*.jar lib/
'opt/flink-gelly_2.11-1.12-SNAPSHOT.jar' -> 'lib/flink-gelly_2.11-1.12-SNAPSHOT.jar'
'opt/flink-gelly-scala_2.11-1.12-SNAPSHOT.jar' -> 'lib/flink-gelly-scala_2.11-1.12-SNAPSHOT.jar'
[corona@cas build-target]$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host cas.
Starting taskexecutor daemon on host cas.
[corona@cas build-target]$ ./bin/flink run examples/gelly/flink-gelly-examples_2.11-1.12-SNAPSHOT.jar --algorithm PageRank --input StarGraph --vertex_count 5 --output Pri
t
Job has been submitted with JobID e9e4a2dc6ee1fe9573354dc3e201028f
Program execution finished
Job with JobID e9e4a2dc6ee1fe9573354dc3e201028f has finished.
Job Runtime: 1947 ms
Accumulator Results:
- fec28a437c597f26a7a6f555a9a94b1e-collect (java.util.ArrayList) [5 elements]
------------------------------------------------------------
The program finished with the following exception:
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:330)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:721)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:947)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1023)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1023)
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.asm.dataset.Collect.getResult(Collect.java:62) [24/126]
at org.apache.flink.graph.asm.dataset.Collect.getResult(Collect.java:35)
at org.apache.flink.graph.asm.dataset.DataSetAnalyticBase.execute(DataSetAnalyticBase.java:56)
at org.apache.flink.graph.drivers.output.Print.write(Print.java:48)
at org.apache.flink.graph.Runner.execute(Runner.java:454)
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:316)
... 8 more
{code}
I found the reason why flink goes wrong after debugging the code remotely, it's simply due to that ContextEnvironment doesn't assign the jobExecutionResult to lastJobExec
utionResult after finishing the job and AnalyticHelper#getAccumulator will get the lastJobExecutionResult, finally things goes wrong.
the logic behind the scene is
{code:java}
// ContextEnvironment#execute(String jobName)
@Override
public JobExecutionResult execute(String jobName) throws Exception {
final JobClient jobClient = executeAsync(jobName);
final List<JobListener> jobListeners = getJobListeners();
try {
final JobExecutionResult jobExecutionResult = getJobExecutionResult(jobClient);
jobListeners.forEach(jobListener ->
jobListener.onJobExecuted(jobExecutionResult, null));
// the missing code
// this.lastJobExecutionResult = jobExecutionResult;
return jobExecutionResult;
} catch (Throwable t) {
jobListeners.forEach(jobListener ->
jobListener.onJobExecuted(null, ExceptionUtils.stripExecutionException(t)));
ExceptionUtils.rethrowException(t);
// never reached, only make javac happy
return null;
}
}
// where the error happens
// AnalyticHelper#getAccumulator(ExecutionEnvironment env, String accumulatorName)
public <A> A getAccumulator(ExecutionEnvironment env, String accumulatorName) {
// the result is null due to the missing assignment to lastJobExecutionResult in ContextEnvironment#execute(String jobName)
JobExecutionResult result = env.getLastJobExecutionResult();
// error raised here
Preconditions.checkNotNull(result, "No result found for job, was execute() called before getting the result?");
return result.getAccumulatorResult(id + SEPARATOR + accumulatorName);
}
{code}
I'd like to fix this problem, can anyone assign me a ticket?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)