THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We propose deprecating the Iteration API of DataStream and removing it completely in the next major version. In the future, if other modules in the Flink repository require the use of the Iteration API, we can consider extracting all Iteration implementations from the Flink ML repository into an independent module.
Public Interfaces
Modify the annotation of these classes and methods to @Deprecated.
| Class / Method | Annotation |
|---|---|
| org.apache.flink.streaming.api.datastream.DataStream#iterate() | PublicEvolving |
org.apache.flink.streaming.api.datastream.DataStream#iterate(long maxWaitTimeMillis) | |
| org.apache.flink.streaming.api.datastream.IterativeStream | |
| org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams | Public |
...
Compatibility, Deprecation, and Migration Plan
N.AThe Iteration API in DataStream will be deprecated in Flink 1.19 and then finally removed in Flink 2.0. For the users that rely on the Iteration API in DataStream, they will have to migrate to Flink ML.
Test Plan
N.A.
Rejected Alternatives
...