There appears to be some issue in DriverTestBase. I have observed two failures recently, once in MatchTaskTest and MapTaskTest, both with the following trace:
Exception in thread "Thread-154" java.lang.AssertionError: Canceling task failed: java.lang.NullPointerException at org.apache.flink.runtime.operators.testutils.DriverTestBase.cancel(DriverTestBase.java:271) at org.apache.flink.runtime.operators.testutils.TaskCancelThread.run(TaskCancelThread.java:60) at org.junit.Assert.fail(Assert.java:88) at org.apache.flink.runtime.operators.testutils.TaskCancelThread.run(TaskCancelThread.java:68) Regards Sachin -- Sachin Goel Computer Science, IIT Delhi m. +91-9871457685
