Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22282

Move creation of SplitEnumerator to the SourceCoordinator thread

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              becket_qin Jiangjie Qin
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: