From c9532a48e999349ae1698f00719fd888fd6b731c Mon Sep 17 00:00:00 2001 From: yangzhg Date: Thu, 4 Jun 2020 12:19:31 +0800 Subject: [PATCH 1/2] add some log to make it easier to find out bug --- fe/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/src/main/java/org/apache/doris/qe/Coordinator.java index 66abaaba4c12be..c6c14670a86131 100644 --- a/fe/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/src/main/java/org/apache/doris/qe/Coordinator.java @@ -409,12 +409,15 @@ public void exec() throws Exception { toBrpcHost(execBeAddr), queryOptions.query_timeout * 1000); + LOG.info("dispatch query job: {} to {}", 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 void exec() throws Exception { List relatedBackendIds = Lists.newArrayList(addressToBackendID.values()); Catalog.getCurrentCatalog().getLoadManager().initJobProgress(jobId, queryId, instanceIds, relatedBackendIds); + LOG.info("dispatch load job: {} to {}", queryId, addressToBackendID.keySet()); } // to keep things simple, make async Cancel() calls wait until plan fragment From 67f82810889e9bb6d19a8fac2829e89c1b451297 Mon Sep 17 00:00:00 2001 From: yangzhg Date: Thu, 4 Jun 2020 19:12:22 +0800 Subject: [PATCH 2/2] fix by comment --- fe/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/src/main/java/org/apache/doris/qe/Coordinator.java index c6c14670a86131..c0b2e85809f8d3 100644 --- a/fe/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/src/main/java/org/apache/doris/qe/Coordinator.java @@ -409,7 +409,7 @@ public void exec() throws Exception { toBrpcHost(execBeAddr), queryOptions.query_timeout * 1000); - LOG.info("dispatch query job: {} to {}", queryId, topParams.instanceExecParams.get(0).host); + 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(); @@ -428,7 +428,7 @@ public void exec() throws Exception { List relatedBackendIds = Lists.newArrayList(addressToBackendID.values()); Catalog.getCurrentCatalog().getLoadManager().initJobProgress(jobId, queryId, instanceIds, relatedBackendIds); - LOG.info("dispatch load job: {} to {}", queryId, addressToBackendID.keySet()); + LOG.info("dispatch load job: {} to {}", DebugUtil.printId(queryId), addressToBackendID.keySet()); } // to keep things simple, make async Cancel() calls wait until plan fragment