[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062351#comment-16062351 ]
Jark Wu commented on FLINK-6958: -------------------------------- [~till.rohrmann] I'm afraid it doesn't work, because the aync io operator hang on the {{checkpointingLock.wait()}} not {{super.close()}} in {{close()}} method. > 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 > Assignee: Jark Wu > > 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 -- This message was sent by Atlassian JIRA (v6.4.14#64029)