Hi all,

I'd like to work on FLINK-31040 and FLINK-31044, and I'm asking a
committer to assign them to me. Both have been open since 2023: when
the window expires before the next event, a looping stage before a
trailing notFollowedBy(...).within(...) loses elements, or with
greedy() the whole match.

The PR is ready and CI is green: https://github.com/apache/flink/pull/29728

Two behaviour changes are worth deciding on early:

Partial matches that were reported on the timeout side output are now
emitted as matches. Tell me if you'd want this behind an option.
With greedy(), a savepoint taken while holding such a partial match
can't be restored into an earlier version.
The PR also fixes a related times(n, m) defect in a separate commit,
because the main fix would otherwise make it worse. I can move it to
its own ticket if you prefer.


Thanks,
Mohammad Bani Hani

Reply via email to