pnowojski commented on a change in pull request #17447: URL: https://github.com/apache/flink/pull/17447#discussion_r727055948
########## File path: docs/content.zh/release-notes/flink-1.14.md ########## @@ -201,6 +201,19 @@ applications do not interfere with each other. ### DataStream API +#### Fixed idleness handling for two/multi input operators + +##### [FLINK-18934](https://issues.apache.org/jira/browse/FLINK-18934) + +##### [FLINK-23767](https://issues.apache.org/jira/browse/FLINK-23767) + +We added `processWatermarkStatusX` method to classes such as `AbstractStreamOperator`, `Input` etc. +It allows to take the `WatermarkStatus` into account when combining watermarks in two/multi input +operators. + +Moreover, we clarified the contract of semi-internal, semi-public `StreamStatus` class and renamed +it to `WatermarkStatus` in order to better reflect its purpose. Review comment: 1. Why `WatermarkStatus` is marked `@Internal` if it's used in `@PublicEvolving` and `@Experimental` classes? 2. "semi-internal, semi-public" sounds very unprofessional. I would just skip this part. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
