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 41e71cd2b0 Eliminate explosion of metrics due to gapfill queries
(#9490)
41e71cd2b0 is described below
commit 41e71cd2b0cfa79870e3c5d989e8efdb3ccb42fa
Author: Elon Azoulay <[email protected]>
AuthorDate: Thu Sep 29 13:52:21 2022 -0700
Eliminate explosion of metrics due to gapfill queries (#9490)
---
.../broker/requesthandler/SingleConnectionBrokerRequestHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandler.java
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandler.java
index 7767afb272..19c081c016 100644
---
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandler.java
+++
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandler.java
@@ -106,7 +106,7 @@ public class SingleConnectionBrokerRequestHandler extends
BaseBrokerRequestHandl
serverBrokerRequest.getPinotQuery().putToQueryOptions(CommonConstants.Broker.Request.TRACE,
"true");
}
- String rawTableName =
TableNameBuilder.extractRawTableName(originalBrokerRequest.getQuerySource().getTableName());
+ String rawTableName =
TableNameBuilder.extractRawTableName(serverBrokerRequest.getQuerySource().getTableName());
long scatterGatherStartTimeNs = System.nanoTime();
AsyncQueryResponse asyncQueryResponse =
_queryRouter.submitQuery(requestId, rawTableName,
offlineBrokerRequest, offlineRoutingTable,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
