You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2020/09/07 02:05:56 UTC
[incubator-doris] 01/04: [Log] Add log for trace broker (#4505)
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 <67...@users.noreply.github.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org