Hi, I downloaded the source tar ball and ran test suite. AsyncWaitOperatorTest hung:
"main" #1 prio=5 os_prio=0 tid=0x00007f02c8008800 nid=0x4b8c in Object.wait() [0x00007f02cf974000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000f1b488a0> (a org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness$TaskThread) at java.lang.Thread.join(Thread.java:1253) - locked <0x00000000f1b488a0> (a org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness$TaskThread) at org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness.waitForTaskCompletion(StreamTaskTestHarness.java:208) at org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness.waitForTaskCompletion(StreamTaskTestHarness.java:193) at org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.testOperatorChainWithProcessingTime(AsyncWaitOperatorTest.java:378) Has anyone else seen this ? Cheers
