(druid) branch master updated: perf: Double default loadahead for MSQ. (#19414)

[gi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gianm 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 09e5e93e3e8 perf: Double default loadahead for MSQ. (#19414)
09e5e93e3e8 is described below

commit 09e5e93e3e8986d42020250178b7f50bc9063907
Author: Gian Merlino <gi...@gmail.com>
AuthorDate: Tue May 5 20:21:17 2026 -0700

    perf: Double default loadahead for MSQ. (#19414)
    
    Setting loadahead to double the number of processing threads provides a
    better likelihood of keeping the processing threads busy. It also
    matches the default number of VSF on-demand loading threads.
---
 .../main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java b/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java
index 1748b528113..240e0b9e75f 100644
--- a/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java
+++ b/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java
@@ -292,7 +292,7 @@ public abstract class BaseLeafStageProcessor extends BasicStageProcessor
     return new ReadableInputQueue(
         new StandardPartitionReader(context),
         filteredSlices,
-        segmentLoadAheadCount != null ? segmentLoadAheadCount : context.threadCount()
+        segmentLoadAheadCount != null ? segmentLoadAheadCount : context.threadCount() * 2
     );
   }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org