Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5912#discussion_r184034674 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java --- @@ -178,7 +172,7 @@ */ @Test public void testEarlyCanceling() throws Exception { - Deadline deadline = new FiniteDuration(2, TimeUnit.MINUTES).fromNow(); --- End diff -- We have our own `Deadline` implementation that is pretty much a drop-in replacement for the scala version.
---