This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e19fd025372 [FLINK-39984][runtime] Dispatch thread dump to ioExecutor
add 77370144cbf [FLINK-40269][tests] Add same-upstream unaligned rescale
ITCase
add 9f867dace15 [FLINK-40269][runtime] Fix channel state assignment for
duplicate connections
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/TaskStateAssignment.java | 106 +++++----
.../checkpoint/StateAssignmentOperationTest.java | 66 ++++++
.../flink/runtime/testutils/CommonTestUtils.java | 13 ++
...alignedCheckpointRescaleSameUpstreamITCase.java | 258 +++++++++++++++++++++
4 files changed, 404 insertions(+), 39 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleSameUpstreamITCase.java
