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

Add some log to make it easier to find out bug (#3770)

Browse Source 
Added some logs to record to which be a query was sent.
Increasing the efficiency of tracing the problem
This commit is contained in:
yangzhg
2020-06-05 10:18:58 +08:00
committed by GitHub
parent fdf3415d06
commit cdd17333ba
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -409,12 +409,15 @@ public class Coordinator {
toBrpcHost(execBeAddr),
queryOptions.query_timeout * 1000);
LOG.info("dispatch query job: {} to {}", DebugUtil.printId(queryId), topParams.instanceExecParams.get(0).host);
// set the broker address for OUTFILE sink
ResultSink resultSink = (ResultSink) topParams.fragment.getSink();
if (resultSink.isOutputFileSink() && resultSink.needBroker()) {
FsBroker broker = Catalog.getCurrentCatalog().getBrokerMgr().getBroker(resultSink.getBrokerName(),
execBeAddr.getHostname());
resultSink.setBrokerAddr(broker.ip, broker.port);
LOG.info("OUTFILE through broker: {}:{}", broker.ip, broker.port);
}
} else {
@ -425,6 +428,7 @@ public class Coordinator {
List<Long> relatedBackendIds = Lists.newArrayList(addressToBackendID.values());
Catalog.getCurrentCatalog().getLoadManager().initJobProgress(jobId, queryId, instanceIds,
relatedBackendIds);
LOG.info("dispatch load job: {} to {}", DebugUtil.printId(queryId), addressToBackendID.keySet());
}
// to keep things simple, make async Cancel() calls wait until plan fragment