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