You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2024/05/01 20:56:57 UTC
(pinot) branch master updated: log the log rate limiter rate for dropped broker logs (#13041)
This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 5d1dc73cc6 log the log rate limiter rate for dropped broker logs (#13041)
5d1dc73cc6 is described below
commit 5d1dc73cc608f5fa8cfea2c72a5fb8a2d112c143
Author: Johan Adami <47...@users.noreply.github.com>
AuthorDate: Wed May 1 16:56:50 2024 -0400
log the log rate limiter rate for dropped broker logs (#13041)
---
.../src/main/java/org/apache/pinot/broker/querylog/QueryLogger.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/querylog/QueryLogger.java b/pinot-broker/src/main/java/org/apache/pinot/broker/querylog/QueryLogger.java
index a1ccd63e6c..28564cc1c6 100644
--- a/pinot-broker/src/main/java/org/apache/pinot/broker/querylog/QueryLogger.java
+++ b/pinot-broker/src/main/java/org/apache/pinot/broker/querylog/QueryLogger.java
@@ -98,7 +98,7 @@ public class QueryLogger {
long numDroppedLogsSinceLastLog = _numDroppedLogs.getAndSet(0);
if (numDroppedLogsSinceLastLog > 0) {
_logger.warn("{} logs were dropped. (log max rate per second: {})", numDroppedLogsSinceLastLog,
- _droppedLogRateLimiter.getRate());
+ _logRateLimiter.getRate());
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org