Jiangjie Qin created FLINK-22282:
------------------------------------

             Summary: Move creation of SplitEnumerator to the SourceCoordinator 
thread
                 Key: FLINK-22282
                 URL: https://issues.apache.org/jira/browse/FLINK-22282
             Project: Flink
          Issue Type: Task
          Components: Connectors / Common
    Affects Versions: 1.12.2
            Reporter: Jiangjie Qin


Currently the creation of the SplitEnumerator is in the JM main thread. In case 
the SplitEnumerator instantiation takes long, the job execution will timeout. 
The fix is moving the SplitEnumerator creation to the coordinator thread.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to