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)

Reply via email to