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