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)