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

["Chesnay Schepler (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767029#comment-17767029 ] 

Chesnay Schepler commented on FLINK-33121:
------------------------------------------

??there are rare cases where multiple concurrent global failures are triggered??

Can you give us an example of when this might happen?

> 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
>            Priority: Major
>
> {{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)