Set 'task.partitioned-writer-count' property to processor count in te…

…stExplicitPropertyMappings test
trinodb · Nov 14, 2022 · e82edd9 · e82edd9
1 parent ee25174
commit e82edd9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/trino-main/src/test/java/io/trino/execution/TestTaskManagerConfig.java b/core/trino-main/src/test/java/io/trino/execution/TestTaskManagerConfig.java
@@ -104,7 +104,7 @@ public void testExplicitPropertyMappings()
                 .put("task.scale-writers.enabled", "false")
                 .put("task.scale-writers.max-writer-count", "4")
                 .put("task.writer-count", "4")
-                .put("task.partitioned-writer-count", "4")
+                .put("task.partitioned-writer-count", Integer.toString(processorCount))
                 .put("task.concurrency", Integer.toString(processorCount))
                 .put("task.http-response-threads", "4")
                 .put("task.http-timeout-threads", "10")
@@ -142,7 +142,7 @@ public void testExplicitPropertyMappings()
                 .setScaleWritersEnabled(false)
                 .setScaleWritersMaxWriterCount(4)
                 .setWriterCount(4)
-                .setPartitionedWriterCount(4)
+                .setPartitionedWriterCount(processorCount)
                 .setTaskConcurrency(processorCount)
                 .setHttpResponseThreads(4)
                 .setHttpTimeoutThreads(10)