Hi all! I want to discuss merging this PR to the 1.11 release branch: https://github.com/apache/flink/pull/12306
It contains the new FLIP-126 Watermarks, and per-partition watermarking to the FLIP-27 sources. In that sense it is partially a new feature after the feature freeze. Hence this discussion, and not just merging. The reasons why I suggest to back-port this to 1.11 are - It is API breaking. Without this patch, we would release a Source API and immediately break compatibility in the next release. - The FLIP-27 feature is experimental, but it should not be useless in the sense that users have to re-write all implemented sources in the next release. - It is a fairly isolated change, does not affect any existing feature in the system Please let me know if you have concerns about this. Best, Stephan
