rmetzger opened a new pull request #15882:
URL: https://github.com/apache/flink/pull/15882


   The Canceling state of Adaptive Scheduler was expecting the ExecutionGraph 
to be in state RUNNING when entering the state.
   However, the Restarting state is cancelling the ExecutionGraph already, thus 
the ExectionGraph can be in state CANCELING or CANCELED when entering the 
Canceling state.
   
    Calling the ExecutionGraph.cancel() method in the Canceling state while 
being in ExecutionGraph.state = CANCELED || CANCELLED is not a problem.
   
   The change is guarded by a new ITCase, as this issue affects the interplay 
between different AS states.


-- 
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]


Reply via email to