Use current name of the configuration property

Was renamed in f85eaab.
trinodb · Mar 5, 2022 · 4175b09 · 4175b09
1 parent 26a176f
commit 4175b09
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java b/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java
@@ -106,7 +106,7 @@ protected final QueryRunner createQueryRunner()
                         .put("failure-injection.request-timeout", new Duration(REQUEST_TIMEOUT.toMillis() * 2, MILLISECONDS).toString())
                         // making http timeouts shorter so tests which simulate communication timeouts finish in reasonable amount of time
                         .put("exchange.http-client.idle-timeout", REQUEST_TIMEOUT.toString())
-                        .put("query.initial-hash-partitions", "5")
+                        .put("query.hash-partition-count", "5")
                         // to trigger spilling
                         .put("exchange.deduplication-buffer-size", "1kB")
                         .buildOrThrow(),

diff --git a/...ino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java b/...ino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java
@@ -25,7 +25,7 @@ public static Map<String, String> getExtraProperties()
     {
         return ImmutableMap.<String, String>builder()
                 .put("retry-policy", "TASK")
-                .put("query.initial-hash-partitions", "5")
+                .put("query.hash-partition-count", "5")
                 .put("fault-tolerant-execution-target-task-input-size", "10MB")
                 .put("fault-tolerant-execution-target-task-split-count", "4")
                 // to trigger spilling