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

SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

    XMLWordPrintableJSON

    Details

      Description

      Currently the split fetchers are only removed from the SplitFetcherManager.fetchers when the thread exit. The may cause problem because when SplitFetcherManager.addSplits() is called, it may see a shutting down split fetcher and adds splits to it. These splits will then just be lost.

      This issue is actually already fixed in FLINK-18128. The fix needs to cherry-picked to 1.11.3

        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:
                Resolved: