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/