Versions Compared

Old Version 7

changes.mady.by.user Paris Carbone

Saved on

compared with

New Version 8

changes.mady.by.user Paris Carbone

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • The Proposed changes in the PublicEvolving Iteration API are not backward compatible and require the following changes:
    • Users need to discard the Iteration Timeout in existing Flink applications
    • All logic within Iterations need to be wrapped within a LoopFunction or CoLoopFunction
    • Binary Operations (union, connect, join, cogroup) are now dissallowed across different loop contexts
    • Chaining is now disabled across operators of different StreamScope (context)
  • The old (currently deprecated) API can still be accessible until a major future release (e.g. Flink v2.0). This is up to discussion.
  • Changes will affect third project integrations of Flink such as the Storm and Samoa compatibility libraries which allow arbitrary loops in the graph and do not require nesting.

...