This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6278f7ac267 [hotfix][runtime] Guard DEBUG log calls with
isDebugEnabled in ZooKeeperLeaderRetrievalDriver
new ffd01f74c6d [FLINK-39140][test] Disable CUSTOM_PARTITIONER in
unaligned checkpoint it case since it does not work well
new abfc3012ba4 [FLINK-39140][test] Allow multiple rescales in Unaligned
Checkpoint ITCases to perform checkpointing during recovery
new 17581beed0c [FLINK-39140][test] Fix MAX_RETAINED_CHECKPOINTS not
effective in UnalignedCheckpointRescaleWithMixedExchangesITCase
new 02e36182d4a [FLINK-39140][test] Change record type from Long to String
in UnalignedCheckpointRescaleWithMixedExchangesITCase
new ebaa7b8420b [hotfix][runtime] Including task name and subtask index
into channel-state-unspilling thread name
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/streaming/runtime/tasks/StreamTask.java | 4 +-
.../checkpointing/UnalignedCheckpointITCase.java | 10 +-
.../UnalignedCheckpointRescaleITCase.java | 79 +++++++++++-----
...dCheckpointRescaleWithMixedExchangesITCase.java | 92 ++++++++++++------
.../checkpointing/UnalignedCheckpointTestBase.java | 103 ++++++++++++++-------
5 files changed, 203 insertions(+), 85 deletions(-)
