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 ;)
---