This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ee2c9d8aac5 [hotfix][network] Fix the notification of inaccurate data
availability in Hybrid Shuffle
add 6c9bb3716a3 [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(-)
