[jira] [Created] (FLINK-33121) Failed precondition in JobExceptionsHandler due to concurrent global failures

["Panagiotis Garefalakis (Jira)" <ji...@apache.org>]

Panagiotis Garefalakis created FLINK-33121:
----------------------------------------------

             Summary: Failed precondition in JobExceptionsHandler due to concurrent global failures
                 Key: FLINK-33121
                 URL: https://issues.apache.org/jira/browse/FLINK-33121
             Project: Flink
          Issue Type: Bug
            Reporter: Panagiotis Garefalakis


{{JobExceptionsHandler#createRootExceptionInfo}} *only* allows concurrent exceptions that are local failures *--* otherwise throws an assertion as part of {{{}asserLocalExceptionInfo{}}}.

However, there are rare cases where multiple concurrent global failures are triggered and added to the failureCollection, before transitioning the job state to Failed e.g., through {{StateWithExecutionGraph#handleGlobalFailure}} of the AdaptiveScheduler.
In this case the last added will be the root and the next one will trigger the assertion 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)