capistrant commented on code in PR #19559:
URL: https://github.com/apache/druid/pull/19559#discussion_r3363403816
##########
multi-stage-query/src/main/java/org/apache/druid/msq/dart/guice/DartWorkerConfig.java:
##########
@@ -41,6 +44,22 @@ public class DartWorkerConfig
@JsonProperty("heapFraction")
private double heapFraction = DEFAULT_HEAP_FRACTION;
+ /**
+ * Worker-local value for the segment load-ahead count used to size segment
prefetch in {@link ReadableInputQueue}.
+ * <p>
+ * Defaults to null (unset), which leaves the value to query context (client
or controller-default supplied) and the
+ * built-in {@code 2 * threadCount} fallback. When set to a positive value,
it acts as a worker-local floor: the
+ * effective count becomes the larger of this value and any value present in
the query context, so a query can still
Review Comment:
fair point, I can make this switch to the selection precedence
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
