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);
         }

Reply via email to