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 <4760722+jadam...@users.noreply.github.com> 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: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org