This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new a276871dd00 Fix call to MemoryIntrospector in
IndexerControllerContext. (#17066)
a276871dd00 is described below
commit a276871dd002dcb422aa3abe724e265bf731f220
Author: Gian Merlino <[email protected]>
AuthorDate: Sat Sep 14 18:10:56 2024 -0700
Fix call to MemoryIntrospector in IndexerControllerContext. (#17066)
This was a logical conflict between #17057 and #17048.
---
.../java/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 e60f1c5c962..42808f64742 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 class IndexerControllerContext implements
ControllerContext
{
// 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();
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
