database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Log] Add log for trace broker (#4505)

Browse Source 
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.
This commit is contained in:
ZhangYu0123
2020-09-06 20:25:08 +08:00
committed by GitHub
parent b780df697a
commit 13e2cf172f
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java
View File

@ -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();

4
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java
View File

@ -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++;
}