Hello, everyone. I am using Flink-Gelly. I got an error when running the example code of Gelly-example. I have reported the problem in Stackoverflow, and this is the link (https://stackoverflow.com/questions/63211746/error-with-flink-gelly-lastjob executionresult-is-null-for-executionenvironment)
I am trying to figure out the error point. I traced the env.execute() function, and it is actually invoked in ContextEnvironment::execute() (link: https://github.com/apache/flink/blob/master/flink-clients/src/main/java/org/ apache/flink/client/program/ContextEnvironment.java#L71). In fact, the variable lastJobExecutionResult (from ContextEnvironment's super class ExecutionEnvironment) is not set. I checked the history of ContextEnvironment, and find that lastJobExecutionResult is exclude from ClusterClient in FLINK-14456 (https://issues.apache.org/jira/browse/FLINK-14456). This is merged to master after flink-1.10. I was wondering If I could set the lastJobExecutionResult in ContextEnvironment::execute() for my case (run Flink-Gelly on flink >= 1.10) without significant side effect. Thank you.