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)

Reply via email to