This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f74a28b [FLINK-25024][docs] Add Changelog backend docs
add 53c3525 [FLINK-25479][rpc] Serialize TaskStateSnapshot when sending
to JM from TM
No new revisions were added by this update.
Summary of changes:
.../checkpoint/CheckpointCoordinatorGateway.java | 5 +-
.../runtime/checkpoint/TaskStateSnapshot.java | 23 +++++
.../apache/flink/runtime/jobmaster/JobMaster.java | 10 +-
.../runtime/state/changelog/SequenceNumber.java | 5 +-
.../flink/runtime/state/changelog/StateChange.java | 6 +-
.../taskexecutor/rpc/RpcCheckpointResponder.java | 9 +-
.../flink/runtime/dispatcher/JobMasterTester.java | 5 +-
.../jobmaster/utils/TestingJobMasterGateway.java | 10 +-
.../state/ttl/mock/MockKeyedStateBackend.java | 50 +++++++---
.../ttl/mock/MockKeyedStateBackendBuilder.java | 9 +-
.../runtime/state/ttl/mock/MockStateBackend.java | 11 ++-
.../changelog/ChangelogKeyedStateBackendTest.java | 3 +-
.../test/checkpointing/StateHandleReuseITCase.java | 104 +++++++++++++++++++++
.../UnalignedCheckpointFailureHandlingITCase.java | 3 +-
14 files changed, 219 insertions(+), 34 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateHandleReuseITCase.java
