...
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 | ||||||
---|---|---|---|---|---|---|
|
...
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
...