This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-0.13 in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 706faaf83eb25fccf0aedca69f5c4fa3c7441134 Author: ZhangYu0123 <[email protected]> AuthorDate: Sun Sep 6 20:25:08 2020 +0800 [Log] Add log for trace broker (#4505) Add tracing broker log. When fe get filestatus for distributing load task to broker, the broker maybe get empty files and not give correct error code. Add this log to easy track which broker process filestatus operation and we can get the error log. --- fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java | 2 +- .../main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java index 9e62c1c..9b641a9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java @@ -408,7 +408,7 @@ public class BrokerUtil { return pair; } - private static TNetworkAddress getAddress(BrokerDesc brokerDesc) throws UserException { + public static TNetworkAddress getAddress(BrokerDesc brokerDesc) throws UserException { FsBroker broker = null; try { String localIP = FrontendOptions.getLocalHostAddress(); diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java index 3d39460..a4cff88 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java @@ -87,8 +87,8 @@ public class BrokerLoadPendingTask extends LoadTask { } tableTotalFileSize += groupFileSize; tableTotalFileNum += fileStatuses.size(); - LOG.info("get {} files in file group {} for table {}. size: {}. job: {}", - fileStatuses.size(), groupNum, entry.getKey(), groupFileSize, callback.getCallbackId()); + LOG.info("get {} files in file group {} for table {}. size: {}. job: {}, broker: {} ", + fileStatuses.size(), groupNum, entry.getKey(), groupFileSize, callback.getCallbackId(), BrokerUtil.getAddress(brokerDesc)); groupNum++; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
