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

          blocks

          Bug - A problem which impairs or prevents the functions of the product. FLINK-20157 SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. FLINK-20114 Fix a few KafkaSource-related bugs

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          links to

          Web Link GitHub Pull Request #14104

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: