[FLINK-17393] Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 27/Apr/20 01:13
• Updated: 15/Nov/20 22:08
• Resolved: 15/Sep/20 20:16

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().

Issue Links

• links to: GitHub Pull Request #13366