This is an automated email from the ASF dual-hosted git repository.
srichter pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from ffa58e1de3d [FLINK-31418][network][tests] Fix unstable test case
SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout
add 2203bc3bdc9 [FLINK-31963][state] Fix rescaling bug in recovery from
unaligned checkpoints. (#22584) (#22595)
No new revisions were added by this update.
Summary of changes:
.../checkpoint/StateAssignmentOperation.java | 28 ++--
.../runtime/checkpoint/TaskStateAssignment.java | 19 ++-
.../checkpoint/StateAssignmentOperationTest.java | 178 ++++++++++++++++++++-
.../checkpointing/UnalignedCheckpointITCase.java | 18 ++-
.../UnalignedCheckpointRescaleITCase.java | 137 ++++++++++------
.../checkpointing/UnalignedCheckpointTestBase.java | 32 +++-
6 files changed, 335 insertions(+), 77 deletions(-)
