This is an automated email from the ASF dual-hosted git repository.
kfaraz 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 1950ea6d6d5 Fix logging lag sample queue max size (#17989)
1950ea6d6d5 is described below
commit 1950ea6d6d52cad9500394d3bcbf763cddf376cd
Author: jtuglu-netflix <[email protected]>
AuthorDate: Thu May 8 19:39:18 2025 -0700
Fix logging lag sample queue max size (#17989)
---
.../seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java
index 2786860ecad..b1446c3d4c1 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java
@@ -123,8 +123,8 @@ public class LagBasedAutoScaler implements
SupervisorTaskAutoScaler
TimeUnit.MILLISECONDS
);
log.info(
- "LagBasedAutoScaler will collect lag every [%d] millis and will keep
[%d] data points for the last [%d] millis for dataSource [%s]",
- lagBasedAutoScalerConfig.getLagCollectionIntervalMillis(),
lagMetricsQueue.size(),
+ "LagBasedAutoScaler will collect lag every [%d] millis and will keep
up to [%d] data points for the last [%d] millis for dataSource [%s]",
+ lagBasedAutoScalerConfig.getLagCollectionIntervalMillis(),
lagMetricsQueue.maxSize(),
lagBasedAutoScalerConfig.getLagCollectionRangeMillis(), dataSource
);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
