From 33723a0e893f36203a652b0110c0d7b43f001b9d Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Sat, 14 Sep 2024 16:53:41 -0700 Subject: [PATCH] Fix call to MemoryIntrospector in IndexerControllerContext. This was a logical conflict between #17057 and #17048. --- .../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(); } /**