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

    https://github.com/apache/flink/pull/6104#discussion_r192428502
  
    --- Diff: 
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
    @@ -383,6 +386,100 @@ public String select(Map<String, List<Event>> 
pattern) {
                env.execute();
        }
     
    +   @Test
    +   public void testSimpleKeyedPatternEventTimeWithSideOutput() throws 
Exception {
    --- End diff --
    
    move the test case to CepOperatorTest, please help review again, thanks ;)


---

Reply via email to