Error with Flink-Gelly, lastJobExecutionResult is null

[Xia Rui <xi...@smail.nju.edu.cn>]

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.