使用异步IO时，数据写入到capacity数后，卡住不再消费source端数据了。

[王敏超]

 AsyncDataStream
      //顺序异步IO
      .orderedWait(input, new AsyncDatabaseRequest(), 5000,
TimeUnit.MILLISECONDS, 1000)

  当我没重写timeout方法的时候，会执行这个报错信息 
resultFuture.completeExceptionally(new TimeoutException("Async function call
has timed out."))


  当我重写了timeout方法，如下，程序就卡住了，求大佬解答。
  override def timeout(input: String, resultFuture: ResultFuture[Int]): Unit
= {
    println("time out ... ")
  }




--
Sent from: http://apache-flink.147419.n8.nabble.com/