Page History

...

Event	Stream Task Status	Operator Status	Final Checkpoint	Stop with Savepoint with Drain	Stop with Savepoint
	RUNNING	RUNNING	-	-	-
			-	-	-
			-	-	-
Aligned on MAX_WATERMARK			Advanced To MAX_WATERMARK and trigger all the event timers	Advanced To MAX_WATERMARK and trigger all the event timers-	N/A (MAX_WATERMARK is not emitted in this case)
			Emit MAX_WATERMARK	Emit MAX_WATERMARK	-N/A
Aligned On EndOfUserRecordsEvent	WAITING_FOR_FINAL_CP	FINISHED	call operator.endInput() & operator.finish()	call operator.endInput() & operator.finish()	-
			Emit EndOfUserRecordsEvent[finished = true]	Emit EndOfUserRecordsEvent[finished = true]	Emit EndOfUserRecordsEvent[finished = false]
Aligned on Checkpoint Barrier			Emit CheckpointBarrier	Emit CheckpointBarrier	Emit CheckpointBarrier
			Wait for Checkpoint / Savepoint Completed	Wait for Checkpoint / Savepoint Completed	Wait for Checkpoint / Savepoint Completed
Checkpoint Completed			Wait for downstream tasks acknowledge EndOfUserRecordsEvent	Wait for downstream tasks acknowledge EndOfUserRecordsEvent	Wait for downstream tasks acknowledge EndOfUserRecordsEvent
Downstream Tasks acknowledge EndOfUserRecordsEvent	CLOSED	CLOSED	-	-
			Call operator.close()	Call operator.close()	Call operator.close()
			Emit EndOfPartitionEvent	Emit EndOfPartitionEvent	Emit EndOfPartitionEvent

...

Page tree