This is an automated email from the ASF dual-hosted git repository. snlee pushed a commit to branch fix-broker-log in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit a0389f09ceec9788943fdce4f7310b64d9ebaefb Author: Seunghyun Lee <[email protected]> AuthorDate: Wed Dec 5 20:51:59 2018 -0800 Fix the bug in broker logging for execution statistics PR #3525 introduced the bug on broker log for execution statistics. This pr resolves the issue. --- .../broker/requesthandler/BaseBrokerRequestHandler.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/pinot-broker/src/main/java/com/linkedin/pinot/broker/requesthandler/BaseBrokerRequestHandler.java b/pinot-broker/src/main/java/com/linkedin/pinot/broker/requesthandler/BaseBrokerRequestHandler.java index 014842c..c06c3ff 100644 --- a/pinot-broker/src/main/java/com/linkedin/pinot/broker/requesthandler/BaseBrokerRequestHandler.java +++ b/pinot-broker/src/main/java/com/linkedin/pinot/broker/requesthandler/BaseBrokerRequestHandler.java @@ -274,13 +274,14 @@ 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):{}/{}/{} servers:{}/{}, groupLimitReached:{}, exceptions:{}, serverStats:{}, query:{}", - requestId, brokerRequest.getQuerySource().getTableName(), totalTimeMs, brokerResponse.getNumDocsScanned(), + "RequestId:{}, table:{}, timeMs:{}, docs:{}/{}, entries:{}/{}, segments(queried/processed/matched):{}/{}/{} " + + "servers:{}/{}, groupLimitReached:{}, exceptions:{}, serverStats:{}, query:{}", requestId, + brokerRequest.getQuerySource().getTableName(), totalTimeMs, brokerResponse.getNumDocsScanned(), brokerResponse.getTotalDocs(), brokerResponse.getNumEntriesScannedInFilter(), - brokerResponse.getNumSegmentsQueried(), brokerResponse.getNumSegmentsProcessed(), brokerResponse.getNumSegmentsMatched(), - brokerResponse.getNumEntriesScannedPostFilter(), brokerResponse.getNumServersResponded(), - brokerResponse.getNumServersQueried(), brokerResponse.isNumGroupsLimitReached(), - brokerResponse.getExceptionsSize(), serverStats.getServerStats(), + brokerResponse.getNumEntriesScannedPostFilter(), brokerResponse.getNumSegmentsQueried(), + brokerResponse.getNumSegmentsProcessed(), brokerResponse.getNumSegmentsMatched(), + brokerResponse.getNumServersResponded(), brokerResponse.getNumServersQueried(), + brokerResponse.isNumGroupsLimitReached(), brokerResponse.getExceptionsSize(), serverStats.getServerStats(), StringUtils.substring(query, 0, _queryLogLength)); return brokerResponse; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
