[FLINK-34660][checkpoint] Parse cluster configuration for AutoRescali…

…ngITCase#testCheckpointRescalingInKeyedState
nicusX · Mar 18, 2024 · e79df35 · e79df35
1 parent 6b5ae44
commit e79df35
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
@@ -234,7 +234,7 @@ public void testCheckpointRescalingKeyedState(boolean scaleOut) throws Exception
 
             JobGraph jobGraph =
                     createJobGraphWithKeyedState(
-                            new Configuration(),
+                            cluster.getMiniCluster().getConfiguration().clone(),
                             parallelism,
                             maxParallelism,
                             numberKeys,