You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sn...@apache.org on 2018/12/06 06:44:30 UTC
[incubator-pinot] branch master updated: Fix the bug in broker
logging for execution statistics (#3587)
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 <sn...@linkedin.com>
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: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org