This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch release-1.18
in repository https://gitbox.apache.org/repos/asf/flink.git
from 94277e18746 [FLINK-32907][Tests] Fix
CheckpointAfterAllTasksFinishedITCase hangs on AZP
add 4868da92497 [FLINK-32945][runtime] Fix NPE when task reached
end-of-data but checkpoint failed
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/scheduler/SchedulerBase.java | 7 +++
.../runtime/scheduler/VertexEndOfDataListener.java | 10 ++++
.../runtime/scheduler/DefaultSchedulerTest.java | 22 ++++++++
.../runtime/scheduler/SchedulerTestingUtils.java | 37 +++++++++----
.../CheckpointAfterAllTasksFinishedITCase.java | 60 +++++++++++++++++++---
5 files changed, 118 insertions(+), 18 deletions(-)
