You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/08/08 09:18:00 UTC

[jira] [Created] (FLINK-13649) Improve error message when job submission was not successful

Timo Walther created FLINK-13649:
------------------------------------

             Summary: Improve error message when job submission was not successful
                 Key: FLINK-13649
                 URL: https://issues.apache.org/jira/browse/FLINK-13649
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Web Frontend
            Reporter: Timo Walther


When submitting a job jar in the web frontend, a user only gets "Internal server error" when something went wrong.

For example, submitting a batch job with {{ExecutionEnvironment env = ExecutionEnvironment.createCollectionsEnvironment();}}.

The logs show a better error message:
{code}
2019-08-08 11:07:18,512 INFO  org.apache.flink.api.java.ExecutionEnvironment                - The job has 0 registered types and 0 default Kryo serializers
2019-08-08 11:07:18,537 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler    - Unhandled exception.
org.apache.flink.client.program.ProgramInvocationException: The program plan could not be fetched - the program aborted pre-maturely.

System.err: (none)

System.out: WC Hello 2

	at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:108)
	at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:80)
	at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toJobGraph(JarHandlerUtils.java:126)
	at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$getJobGraphAsync$6(JarRunHandler.java:142)
	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
{code}



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)