Dawid Wysakowicz created FLINK-23532:
----------------------------------------
Summary: Unify stop-with-savepoint w drain and w/o drain
Key: FLINK-23532
URL: https://issues.apache.org/jira/browse/FLINK-23532
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing, Runtime / Task
Reporter: Dawid Wysakowicz
The code paths for stop-with-savepoint --drain and w/o drain are different
after FLINK23408. We should unify the two and in both cases we should wait for
the savepoint in afterInvoke and e.g. close the source thread before triggering
the last checkpoint.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)