This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit be628c67b150b03b316b55f09a7292939de21c0c
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Thu Feb 4 09:09:11 2021 +0100
[hotfix] Fix RocksIncrementalCheckpointRescalingTest
Few cases that were checked in the test are actually illegal
combination. They were testing keys that should never end up in a given
sub task as they do not belong to a key group owned by the task.
---
.../RocksIncrementalCheckpointRescalingTest.java | 42 ----------------------
1 file changed, 42 deletions(-)
diff --git
a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java
b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java
index 580c35b..baf418f 100644
---
a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java
+++
b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java
@@ -187,12 +187,6 @@ public class RocksIncrementalCheckpointRescalingTest
extends TestLogger {
snapshot2 =
AbstractStreamOperatorTestHarness.repackageState(
harness2[0].snapshot(0, 0),
harness2[1].snapshot(0, 0));
-
- validHarnessResult(
- harness2[0], 1, records[5], records[6], records[7],
records[8], records[9]);
-
- validHarnessResult(
- harness2[1], 1, records[0], records[1], records[2],
records[3], records[4]);
} finally {
closeHarness(harness2);
}
@@ -253,36 +247,6 @@ public class RocksIncrementalCheckpointRescalingTest
extends TestLogger {
validHarnessResult(harness3[0], 3, records[0], records[1],
records[2], records[3]);
validHarnessResult(harness3[1], 3, records[4], records[5],
records[6]);
validHarnessResult(harness3[2], 3, records[7], records[8],
records[9]);
-
- validHarnessResult(
- harness3[0],
- 1,
- records[4],
- records[5],
- records[6],
- records[7],
- records[8],
- records[9]);
- validHarnessResult(
- harness3[1],
- 1,
- records[0],
- records[1],
- records[2],
- records[3],
- records[7],
- records[8],
- records[9]);
- validHarnessResult(
- harness3[2],
- 1,
- records[0],
- records[1],
- records[2],
- records[3],
- records[4],
- records[5],
- records[6]);
} finally {
closeHarness(harness3);
}
@@ -390,12 +354,6 @@ public class RocksIncrementalCheckpointRescalingTest
extends TestLogger {
snapshot2 =
AbstractStreamOperatorTestHarness.repackageState(
harness2[0].snapshot(0, 0),
harness2[1].snapshot(0, 0));
-
- validHarnessResult(
- harness2[0], 1, records[5], records[6], records[7],
records[8], records[9]);
-
- validHarnessResult(
- harness2[1], 1, records[0], records[1], records[2],
records[3], records[4]);
} finally {
closeHarness(harness2);
}
