Hi Xia Rui, thanks for reporting this issue. I think FLINK-15116 [1] caused the regression. The problem is indeed that we no longer set the lastJobExecutionResult when using the ContextEnvironment. The problem has not surfaced since with other ExecutionEnvironments, we still set the field correctly. I'm pulling in Aljoscha, Klou and Tison who worked on this feature. I believe they can propose a fix for the problem.
[1] https://issues.apache.org/jira/browse/FLINK-15116 On Sun, Aug 2, 2020 at 11:28 AM Xia Rui <xia...@smail.nju.edu.cn> wrote: > 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 > <https://stackoverflow.com/questions/63211746/error-with-flink-gelly-lastjobexecutionresult-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 > <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. > >
