[incubator-pinot] branch master updated: Add Broker Reduce Time Log (#6033)

[xiangfu]

This is an automated email from the ASF dual-hosted git repository.

xiangfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new 73f0459  Add Broker Reduce Time Log (#6033)
73f0459 is described below

commit 73f0459dc0f173d75dbff56ca66ea670e484ef4a
Author: Yash Agarwal <yash.0...@gmail.com>
AuthorDate: Sun Sep 20 13:35:30 2020 +0530

    Add Broker Reduce Time Log (#6033)
---
 .../apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java
 
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java
index 792534d..4925781 100644
--- 
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java
+++ 
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java
@@ -406,7 +406,7 @@ public abstract class BaseBrokerRequestHandler implements 
BrokerRequestHandler {
       // Table name might have been changed (with suffix _OFFLINE/_REALTIME 
appended)
       LOGGER.info("requestId={},table={},timeMs={},docs={}/{},entries={}/{},"
               + 
"segments(queried/processed/matched/consuming/unavailable):{}/{}/{}/{}/{},consumingFreshnessTimeMs={},"
-              + 
"servers={}/{},groupLimitReached={},exceptions={},serverStats={},query={}", 
requestId,
+              + 
"servers={}/{},groupLimitReached={},brokerReduceTimeMs={},exceptions={},serverStats={},query={}",
 requestId,
           brokerRequest.getQuerySource().getTableName(), totalTimeMs, 
brokerResponse.getNumDocsScanned(),
           brokerResponse.getTotalDocs(), 
brokerResponse.getNumEntriesScannedInFilter(),
           brokerResponse.getNumEntriesScannedPostFilter(), 
brokerResponse.getNumSegmentsQueried(),
@@ -414,7 +414,7 @@ public abstract class BaseBrokerRequestHandler implements 
BrokerRequestHandler {
           brokerResponse.getNumConsumingSegmentsQueried(), 
numUnavailableSegments,
           brokerResponse.getMinConsumingFreshnessTimeMs(), 
brokerResponse.getNumServersResponded(),
           brokerResponse.getNumServersQueried(), 
brokerResponse.isNumGroupsLimitReached(),
-          brokerResponse.getExceptionsSize(), serverStats.getServerStats(),
+          requestStatistics.getReduceTimeMillis(), 
brokerResponse.getExceptionsSize(), serverStats.getServerStats(),
           StringUtils.substring(query, 0, _queryLogLength));
 
       // Limit the dropping log message at most once per second.


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org