Eliminate explosion of metrics due to gapfill queries (apache#9490)

61yao · Oct 3, 2022 · ce078f1 · ce078f1
1 parent 802390b
commit ce078f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandler.java b/...ain/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,