You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "xingbe (Jira)" <ji...@apache.org> on 2024/06/05 01:23:00 UTC

[jira] [Created] (FLINK-35522) The source task may get stuck after a failover occurs in batch jobs

xingbe created FLINK-35522:
------------------------------

             Summary: The source task may get stuck after a failover occurs in batch jobs
                 Key: FLINK-35522
                 URL: https://issues.apache.org/jira/browse/FLINK-35522
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.18.1, 1.19.0, 1.17.2, 1.20.0
            Reporter: xingbe
             Fix For: 1.20.0


If the source task does not get assigned a split because the SplitEnumerator has no more splits, and a failover occurs during the closing process, the SourceCoordinatorContext will not resend the NoMoreSplit event to the newly started source task, causing the source vertex to remain stuck indefinitely. 
This case may only occur in batch jobs where speculative execution has been enabled.



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