From 670e4bc85c5d8537ee032dca04df04ea8c1d09fb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Osipiuk?= Date: Thu, 26 Sep 2024 18:17:02 +0200 Subject: [PATCH] Bump default value for maximum tasks waiting for node per query --- .../src/main/java/io/trino/execution/QueryManagerConfig.java | 2 +- .../test/java/io/trino/execution/TestQueryManagerConfig.java | 2 +- docs/src/main/sphinx/admin/fault-tolerant-execution.md | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/core/trino-main/src/main/java/io/trino/execution/QueryManagerConfig.java b/core/trino-main/src/main/java/io/trino/execution/QueryManagerConfig.java index 74ceac6ff3498c..de3e60096b2d5b 100644 --- a/core/trino-main/src/main/java/io/trino/execution/QueryManagerConfig.java +++ b/core/trino-main/src/main/java/io/trino/execution/QueryManagerConfig.java @@ -109,7 +109,7 @@ public class QueryManagerConfig private double retryDelayScaleFactor = 2.0; private int maxTasksWaitingForExecutionPerQuery = 10; - private int maxTasksWaitingForNodePerQuery = 5; + private int maxTasksWaitingForNodePerQuery = 50; private boolean enabledAdaptiveTaskRequestSize = true; private DataSize maxRemoteTaskRequestSize = DataSize.of(8, MEGABYTE); diff --git a/core/trino-main/src/test/java/io/trino/execution/TestQueryManagerConfig.java b/core/trino-main/src/test/java/io/trino/execution/TestQueryManagerConfig.java index 6c3af821915b46..bd2e0c6ae35a5c 100644 --- a/core/trino-main/src/test/java/io/trino/execution/TestQueryManagerConfig.java +++ b/core/trino-main/src/test/java/io/trino/execution/TestQueryManagerConfig.java @@ -79,7 +79,7 @@ public void testDefaults() .setRetryMaxDelay(new Duration(1, MINUTES)) .setRetryDelayScaleFactor(2.0) .setMaxTasksWaitingForExecutionPerQuery(10) - .setMaxTasksWaitingForNodePerQuery(5) + .setMaxTasksWaitingForNodePerQuery(50) .setEnabledAdaptiveTaskRequestSize(true) .setMaxRemoteTaskRequestSize(DataSize.of(8, DataSize.Unit.MEGABYTE)) .setRemoteTaskRequestSizeHeadroom(DataSize.of(2, DataSize.Unit.MEGABYTE)) diff --git a/docs/src/main/sphinx/admin/fault-tolerant-execution.md b/docs/src/main/sphinx/admin/fault-tolerant-execution.md index c1a19cb7563aa6..8676ebeb4e05d4 100644 --- a/docs/src/main/sphinx/admin/fault-tolerant-execution.md +++ b/docs/src/main/sphinx/admin/fault-tolerant-execution.md @@ -366,7 +366,7 @@ fault-tolerant execution: * - `max-tasks-waiting-for-node-per-query` - Allow for up to configured number of tasks to wait for node allocation per query, before pausing scheduling for other tasks from this query. - - 5 + - `50` - Only `TASK` :::