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 315059e844 add metric for multstiage num groups limit reached (#15221)
315059e844 is described below
commit 315059e844682ca43e873c9c4392a09fbe1b3b06
Author: Johan Adami <[email protected]>
AuthorDate: Tue Mar 18 14:58:58 2025 -0400
add metric for multstiage num groups limit reached (#15221)
---
.../broker/requesthandler/MultiStageBrokerRequestHandler.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java
index 8e958cf692..14d9cca45a 100644
---
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java
+++
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java
@@ -385,6 +385,13 @@ public class MultiStageBrokerRequestHandler extends
BaseBrokerRequestHandler {
fillOldBrokerResponseStats(brokerResponse, queryResults.getQueryStats(),
dispatchableSubPlan);
+ // Track number of queries with number of groups limit reached
+ if (brokerResponse.isNumGroupsLimitReached()) {
+ for (String table : tableNames) {
+ _brokerMetrics.addMeteredTableValue(table,
BrokerMeter.BROKER_RESPONSES_WITH_NUM_GROUPS_LIMIT_REACHED, 1);
+ }
+ }
+
// Set total query processing time
// TODO: Currently we don't emit metric for QUERY_TOTAL_TIME_MS
long totalTimeMs = System.currentTimeMillis() -
requestContext.getRequestArrivalTimeMillis();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
