Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191757079
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -212,6 +212,20 @@ public static void countDown() {
}
}
+ private static class TimeoutAwareLazyAsyncFunction extends
LazyAsyncFunction {
--- End diff --
rename to `IgnoreTimeoutLazyAsyncFunction` ?---
