File tree Expand file tree Collapse file tree 2 files changed +26
-0
lines changed Expand file tree Collapse file tree 2 files changed +26
-0
lines changed Original file line number Diff line number Diff line change @@ -201,6 +201,19 @@ applications do not interfere with each other.
201
201
202
202
### DataStream API
203
203
204
+ #### Fixed idleness handling for two/multi input operators
205
+
206
+ ##### [ FLINK-18934] ( https://issues.apache.org/jira/browse/FLINK-18934 )
207
+
208
+ ##### [ FLINK-23767] ( https://issues.apache.org/jira/browse/FLINK-23767 )
209
+
210
+ We added ` processWatermarkStatusX ` method to classes such as ` AbstractStreamOperator ` , ` Input ` etc.
211
+ It allows to take the ` WatermarkStatus ` into account when combining watermarks in two/multi input
212
+ operators.
213
+
214
+ Note that with this release, we renamed the previously internal ` StreamStatus ` to ` WatermarkStatus `
215
+ in order to better reflect its purpose.
216
+
204
217
#### Allow @TypeInfo annotation on POJO field declarations
205
218
206
219
##### [ FLINK-12141] ( https://issues.apache.org/jira/browse/FLINK-12141 )
Original file line number Diff line number Diff line change @@ -201,6 +201,19 @@ applications do not interfere with each other.
201
201
202
202
### DataStream API
203
203
204
+ #### Fixed idleness handling for two/multi input operators
205
+
206
+ ##### [ FLINK-18934] ( https://issues.apache.org/jira/browse/FLINK-18934 )
207
+
208
+ ##### [ FLINK-23767] ( https://issues.apache.org/jira/browse/FLINK-23767 )
209
+
210
+ We added ` processWatermarkStatusX ` method to classes such as ` AbstractStreamOperator ` , ` Input ` etc.
211
+ It allows to take the ` WatermarkStatus ` into account when combining watermarks in two/multi input
212
+ operators.
213
+
214
+ Note that with this release, we renamed the previously internal ` StreamStatus ` to ` WatermarkStatus `
215
+ in order to better reflect its purpose.
216
+
204
217
#### Allow @TypeInfo annotation on POJO field declarations
205
218
206
219
##### [ FLINK-12141] ( https://issues.apache.org/jira/browse/FLINK-12141 )
You can’t perform that action at this time.
0 commit comments