From ce078f1b53db019fb06e7f30d2455dd4b8a57c5a Mon Sep 17 00:00:00 2001 From: Elon Azoulay Date: Thu, 29 Sep 2022 13:52:21 -0700 Subject: [PATCH] Eliminate explosion of metrics due to gapfill queries (#9490) --- .../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 7767afb27210..19c081c016b6 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 @@ protected BrokerResponseNative processBrokerRequest(long requestId, BrokerReques 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,