[
https://issues.apache.org/jira/browse/FLINK-23532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-23532:
-------------------------------------
Description: The code paths for stop-with-savepoint --drain and w/o drain
are different after FLINK-23408. 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. (was: 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.)
> 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
> Priority: Major
>
> The code paths for stop-with-savepoint --drain and w/o drain are different
> after FLINK-23408. 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)
