Versions Compared

Old Version 3

changes.mady.by.user Kostas Kloudas

Saved on

compared with

New Version 4

changes.mady.by.user Chesnay Schepler

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: add discussion link

...

Current state: Accepted

Discussion thread:  here (<- link to https://mail-archiveslists.apache.org/thread.html/b8d2f3209e7ca7467af6037383ade6c14c35276f7acb2bbbc9a50c0f@%3Cdev.flink.apache.org%3Emod_mbox/flink-dev/)

JIRA: 

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-11458

...

The following table illustrates the differences between the two new operations from an operator/task perspective.



Source OPS

Task Status

Job Status

SUSPEND

Checkpoint Barrier,

End Of Stream

Finished

Finished

TERMINATE

MAX_WATERMARK, Checkpoint Barrier,

End Of Stream

Finished

Finished


User-Facing Changes


  • Expose the new SUSPEND and TERMINATE operations through REST to the user

  • Change event time semantics in accordance with the above table

...