From 4175b09589c79ad888dfcb2805bb1d85c0cf347f Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Thu, 3 Mar 2022 23:24:39 +0100 Subject: [PATCH] Use current name of the configuration property Was renamed in f85eaabaff57953713e43b006f602f14d9541fe0. --- .../src/main/java/io/trino/testing/BaseFailureRecoveryTest.java | 2 +- .../testing/FaultTolerantExecutionConnectorTestHelper.java | 2 +- 2 files changed, 2 insertions(+), 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 index 07e7d343e626..72c3912ceac9 100644 --- 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/testing/trino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java b/testing/trino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java index 1ac2a00c559d..efb7ee80848f 100644 --- a/testing/trino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java +++ b/testing/trino-testing/src/main/java/io/trino/testing/FaultTolerantExecutionConnectorTestHelper.java @@ -25,7 +25,7 @@ public static Map getExtraProperties() { return ImmutableMap.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