aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to 
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563224522
 
 
   @zjffdu @TisonKun I know this is the third try at this, so sorry for that. 😅
   
   @zjffdu I changed the `JobListener` interface to take a future, to bring it 
in line with the return value of `executeAsync()`. This also allows calling the 
listener in the main thread (which you need for Zeppelin). I also addded tests 
that ensure we call the listener on the main thread.
   
   We should discuss the return value of `executeAsync()` in 
https://issues.apache.org/jira/browse/FLINK-15129.
   
   I will open a Jira issue for the Scala Shell changes that you require and 
can also add that.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to