From 3ac46d1e4b3b74133a8c560f96dd6353c6eada34 Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Sat, 14 Sep 2024 17:45:22 -0700 Subject: [PATCH] fix IndexerControllerContext for api change --- .../org/apache/druid/msq/indexing/IndexerControllerContext.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java index e60f1c5c9622..42808f647426 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java @@ -206,7 +206,7 @@ public int defaultTargetPartitionsPerWorker() { // Assume tasks are symmetric: workers have the same number of processors available as a controller. // Create one partition per processor per task, for maximum parallelism. - return memoryIntrospector.numProcessorsInJvm(); + return memoryIntrospector.numProcessingThreads(); } /**