Chesnay Schepler created FLINK-21380: ----------------------------------------
Summary: Restarting/Canceling/Failing expose globally-terminal EG Key: FLINK-21380 URL: https://issues.apache.org/jira/browse/FLINK-21380 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination Reporter: Chesnay Schepler Assignee: Chesnay Schepler Fix For: 1.13.0 When the declarative scheduler is in the Restarting state it can expose a fully Canceled EG, because it only overrides {{getJobStatus}}, but the archived execution graph still contains the Canceled job state. This breaks the contract that the EG only transitions into a terminal state once, and never transitions into another state afterwards. Related to that the Canceling/Failing states can also expose such an EG because {{State#onGloballyTerminalState}} is called asynchronously. A globally-terminal EG should only be visible in the Finished state however. -- This message was sent by Atlassian Jira (v8.3.4#803005)