[jira] [Created] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

Shang Yuanchun (Jira)
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)