[FLINK-6958] Async I/O timeout not work

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Affects Version/s: 1.2.1
• Component/s: API / DataStream
• Labels: pull-request-available stale-assigned
• Assignee: Jark Wu
• Reporter: feng xiaojie
• Created: 21/Jun/17 04:22
• Updated: 20/Apr/21 06:57
• Resolved: 20/Apr/21 06:57

Description

when use Async I/O with UnorderedStreamElementQueue, the queue will always full if you don't call the AsyncCollector.collect to ack them.
Timeout shall collect these entries when the timeout trigger,but it isn't work
I debug find,
when time out, it will call resultFuture.completeExceptionally(error);
but not call UnorderedStreamElementQueue.onCompleteHandler
it will cause that async i/o hang always

Issue Links

• links to: GitHub Pull Request #4189
• links to: GitHub Pull Request #4189