Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4673
Hi @yestinchen ,
thanks for spotting the mistake. Good catch. However the test you provided
does not prove the fix. It passes with and without the fix. Please correct it.
You can e.g. extend the Pattern like this:
Pattern<Tuple2<Integer, String>, ?> pattern =
Pattern.<Tuple2<Integer, String>>begin("start",
AfterMatchSkipStrategy.skipPastLastEvent())
.where(new SimpleCondition<Tuple2<Integer, String>>() {
@Override
public boolean filter(Tuple2<Integer, String>
rec) throws Exception {
return rec.f1.equals("a");
}
}).times(2);
Then the expected output would be:
expected = "(1,a)\n(3,a)";
---
