[FLINK-19801][tests] Adding rescaling IT for unaligned checkpoints.

weichunshen89 · Mar 11, 2021 · b4c57c0 · b4c57c0
1 parent f15d454
commit b4c57c0
Show file tree

Hide file tree

Showing 4 changed files with 507 additions and 33 deletions.
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java
@@ -145,7 +145,6 @@ private static UnalignedSettings createPipelineSettings(
                 .setParallelism(parallelism)
                 .setSlotSharing(slotSharing)
                 .setNumSlots(slotSharing ? parallelism : parallelism * numShuffles)
-                .setNumBuffers(getNumBuffers(parallelism, numShuffles))
                 .setSlotsPerTaskManager(slotsPerTaskManager)
                 .setExpectedFailures(5)
                 .setFailuresAfterSourceFinishes(1)
@@ -158,7 +157,6 @@ private static UnalignedSettings createCogroupSettings(int parallelism) {
                 .setParallelism(parallelism)
                 .setSlotSharing(true)
                 .setNumSlots(parallelism * numShuffles)
-                .setNumBuffers(getNumBuffers(parallelism, numShuffles))
                 .setSlotsPerTaskManager(parallelism)
                 .setExpectedFailures(5)
                 .setFailuresAfterSourceFinishes(1);
@@ -170,7 +168,6 @@ private static UnalignedSettings createUnionSettings(int parallelism) {
                 .setParallelism(parallelism)
                 .setSlotSharing(true)
                 .setNumSlots(parallelism * numShuffles)
-                .setNumBuffers(getNumBuffers(parallelism, numShuffles))
                 .setSlotsPerTaskManager(parallelism)
                 .setExpectedFailures(5)
                 .setFailuresAfterSourceFinishes(1);