feng xiaojie created FLINK-6958: ----------------------------------- Summary: Async I/O timeout not work Key: FLINK-6958 URL: https://issues.apache.org/jira/browse/FLINK-6958 Project: Flink Issue Type: Bug Components: Streaming Affects Versions: 1.2.1 Reporter: feng xiaojie
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, it will call resultFuture.completeExceptionally(error); but wiil not call UnorderedStreamElementQueue.onCompleteHandler -- This message was sent by Atlassian JIRA (v6.4.14#64029)