Hi all, We would like to start the vote for FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag [1]. This FLIP was discussed in this thread [2].
The vote will be open until at least Oct 21st (at least 72 hours), following the consensus voting process. Cheers, Xuannan [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-328%3A+Allow+source+operators+to+determine+isProcessingBacklog+based+on+watermark+lag [2] https://lists.apache.org/thread/kmtyqxsp35cobx3g0kwfn6ksxlq57m4t
