Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6170#discussion_r197716214
  
    --- Diff: 
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
    @@ -229,7 +206,7 @@ public void testSimplePatternEventTime() throws 
Exception {
                        Tuple2.of(new Event(4, "end", 4.0), 10L),
                        Tuple2.of(new Event(5, "middle", 5.0), 7L),
                        // last element for high final watermark
    -                   Tuple2.of(new Event(5, "middle", 5.0), 100L)
    +                   Tuple2.of(new Event(6, "middle", 5.0), 100L)
    --- End diff --
    
    why is this change necessary?


---

Reply via email to