This is an automated email from the ASF dual-hosted git repository.
snlee 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 1211b22 Fix the bug in broker logging for execution statistics (#3587)
1211b22 is described below
commit 1211b221ab3b9f1a468f723d5a8c28bfdd726bfa
Author: Seunghyun Lee <[email protected]>
AuthorDate: Wed Dec 5 22:44:26 2018 -0800
Fix the bug in broker logging for execution statistics (#3587)
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]
