Due to OptimizerPlanEnvironment.execute() throwing exception on the last line there is not way to post-process batch job execution result, like:
JobExecutionResult r = env.execute(); // execute batch job analyzeResult(r); // this will never get executed due to plan optimization https://github.com/apache/flink/blob/master/flink-clients/src/main/java/org/apache/flink/client/program/OptimizerPlanEnvironment.java#L54 Is there any way to allow such post-processing in batch jobs? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
