Add Broker Reduce Time Log
@@ -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.
