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

SourceCoordinator should catch exception thrown from SplitEnumerator.start()

    XMLWordPrintableJSON

    Details

      Description

      This is a bug introduced in FLINK-18323 where we put SplitEnumrator.start() into the CoordinatorExecutor without catching exception. The fix is catching exception thrown from SplitEnumerator.start() and fail the job accordingly, just like the other method delegated to the CoordinatorExecutor.

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: