Hi all, I would like to start a discussion on FLIP-443: Interruptible watermark processing.
https://cwiki.apache.org/confluence/x/qgn9EQ This proposal tries to make Flink's subtask thread more responsive when processing watermarks/firing timers, and make those operations interruptible/break them apart into smaller steps. At the same time, the proposed solution could be potentially adopted in other places in the code base as well, to solve similar problems with other flatMap-like operators (non windowed joins, aggregations, CepOperator, ...). I'm looking forward to your thoughts. Best, Piotrek
