Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10740 FLIP-27: Refactor Source Interface
  3. FLINK-17393

Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

    XMLWordPrintableJSON

    Details

      Description

      Currently, if a FetchTask is blocking on FutureCompletingBlockingQueue.put(), interrupt has to be called to wake it up, which will result in InterruptedException. We can avoid the interruption by having our own implementation of BlockingQueue.Put().

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: