Dear devs, We recently discovered that StreamStatus and Idleness is insufficiently defined [1], so I drafted a FLIP [3] to amend that situation. It would be good to hear more opinions on that matter. Ideally, we can make the changes to 1.14 as some newly added methods are affected.
Best, Arvid [1] https://lists.apache.org/thread.html/r5194e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e%40%3Cdev.flink.apache.org%3E [2] https://lists.apache.org/thread.html/rb871f5aecbca6e5d786303557a6cdb3d425954385cbdb1b777f2fcf5%40%3Cdev.flink.apache.org%3E [3] https://cwiki.apache.org/confluence/display/FLINK/FLIP-180%3A+Adjust+StreamStatus+and+Idleness+definition