walterddr commented on code in PR #11023:
URL: https://github.com/apache/pinot/pull/11023#discussion_r1263767555
##########
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java:
##########
@@ -247,6 +247,12 @@ private BrokerResponse handleRequest(long requestId,
String query, @Nullable Sql
// find a way to split metrics in case of multiple table
String rawTableName =
TableNameBuilder.extractRawTableName(tableNames.iterator().next());
entry.getValue().setStageLevelStats(rawTableName, brokerResponseStats,
_brokerMetrics);
+
+ // Track number of queries with number of groups limit reached
+ if (brokerResponse.isNumGroupsLimitReached()) {
Review Comment:
just a quick thought. do we need to handle the "group-limit" metrics
emission on broker? cant we do this on the servers and would that make more
sense?
- upon checking the group-by reducer code on broker it doesn't actually
apply the group limit,
- only place it is applied and trimmed result is on server group-by-operator
and combine
- v2 intermediate stage also will apply limit but at that point the "table"
info is lost.
does it make sense to directly emit the metrics on server?
--
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: commits-unsubscr...@pinot.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
