[GitHub] flink pull request #6170: [FLINK-9563]: Using a custom sink function for tes...

[zentol]

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

    https://github.com/apache/flink/pull/6170#discussion_r197717352
  
    --- Diff: 
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
    @@ -666,12 +654,17 @@ public String select(Map<String, List<Event>> 
pattern) {
                        }
                );
     
    -           result.writeAsText(resultPath, FileSystem.WriteMode.OVERWRITE);
    +           List<String> resultList = new ArrayList<>();
    +
    +           
DataStreamUtils.collect(result).forEachRemaining(resultList::add);
    +
    +           List<String> expected = 
Arrays.asList("1,6,4\n1,5,4".split("\n"));
    --- End diff --
    
    same as above


---