This is an automated email from the ASF dual-hosted git repository.
leiyanfei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 547e4b53ebe [FLINK-35270]Enrich information in logs, making it easier
for debugging
add 4fe66e06974 [FLINK-32084][checkpoint] Migrate current file merging of
channel state snapshot into the unify file merging framework
No new revisions were added by this update.
Summary of changes:
.../ChannelStateWriteRequestDispatcherImpl.java | 20 +++++-----
.../ChannelStateWriteRequestExecutorFactory.java | 24 +++++++++---
.../checkpoint/channel/ChannelStateWriterImpl.java | 13 ++++---
.../filesystem/FsCheckpointStorageAccess.java | 1 -
.../FsMergingCheckpointStorageAccess.java | 6 ++-
...ChannelStateWriteRequestDispatcherImplTest.java | 12 ++----
.../ChannelStateWriteRequestDispatcherTest.java | 3 +-
...hannelStateWriteRequestExecutorFactoryTest.java | 11 ++++--
.../ChannelStateWriteRequestExecutorImplTest.java | 3 +-
.../channel/ChannelStateWriterImplTest.java | 12 ++++--
.../operators/testutils/DummyEnvironment.java | 14 +++++++
.../runtime/state/ChannelPersistenceITCase.java | 4 +-
.../environment/ExecutionCheckpointingOptions.java | 9 +++++
.../flink/streaming/runtime/tasks/StreamTask.java | 43 ++++++++++++++++++----
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 43 +++-------------------
.../MockSubtaskCheckpointCoordinatorBuilder.java | 27 ++++++++------
.../runtime/tasks/StreamMockEnvironment.java | 11 ++++++
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 4 ++
.../tasks/SubtaskCheckpointCoordinatorTest.java | 10 ++++-
19 files changed, 166 insertions(+), 104 deletions(-)
