Bump default value for maximum tasks waiting for node per query

trinodb · Sep 26, 2024 · 670e4bc · 670e4bc
1 parent 621a809
commit 670e4bc
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 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
@@ -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
@@ -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
@@ -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`
 :::