This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 13e2cf1 [Log] Add log for trace broker (#4505)
13e2cf1 is described below
commit 13e2cf172f831ff9d754505dd4564f48ef213ff5
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]
