Dawid Wysakowicz created FLINK-23541:
----------------------------------------
Summary: Call StreamOperator#finish on EndOfData
Key: FLINK-23541
URL: https://issues.apache.org/jira/browse/FLINK-23541
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing
Reporter: Dawid Wysakowicz
Fix For: 1.14.0
We want to be able to bring the entire topology with a single
checkpoint/savepoint. In order to do that we must be able to call finish on all
operators before such a checkpoint is triggered. The idea is to emit EndOfData,
which once received, triggers finish()/endInput(). After such a sequence we can
trigger a checkpoint/savepoint which meets the aforementioned criteria.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
