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.


---

Reply via email to