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