This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c0c33d3 [FLINK-24158][runtime] Remove useless collector in
LimitOperator
add 67150da Revert "[FLINK-23759][runtime][checkpoint] Ignore the
restored checkpoints when reporting latest completed id with abortion message"
add 888b365 [FLINK-24096][checkpoint] Skip the complete notification for
checkpoints before task startup
No new revisions were added by this update.
Summary of changes:
.../api/runtime/SavepointTaskStateManager.java | 7 ++
.../runtime/checkpoint/CheckpointCoordinator.java | 14 +---
.../checkpoint/CompletedCheckpointStore.java | 15 +++++
.../flink/runtime/state/TaskStateManager.java | 5 ++
.../flink/runtime/state/TaskStateManagerImpl.java | 11 ++++
.../checkpoint/CheckpointCoordinatorTest.java | 74 ----------------------
.../checkpoint/CompletedCheckpointStoreTest.java | 15 +++++
.../runtime/state/TaskStateManagerImplTest.java | 22 +++++++
.../flink/runtime/state/TestTaskStateManager.java | 12 ++++
.../flink/streaming/runtime/tasks/StreamTask.java | 5 ++
.../runtime/tasks/MultipleInputStreamTaskTest.java | 4 +-
.../tasks/SourceOperatorStreamTaskTest.java | 4 +-
.../runtime/tasks/SourceStreamTaskTest.java | 4 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 33 ++++++++++
14 files changed, 133 insertions(+), 92 deletions(-)
