Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6170#discussion_r195823948 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java --- @@ -360,27 +345,30 @@ public boolean filter(Event value) throws Exception { }); DataStream<String> result = CEP.pattern(input, pattern).select( - new PatternSelectFunction<Event, String>() { + new PatternSelectFunction<Event, String>() { - @Override - public String select(Map<String, List<Event>> pattern) { - StringBuilder builder = new StringBuilder(); + @Override --- End diff -- indendation changes that weren't reversed
---