This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch opt_dict_perf
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/opt_dict_perf by this push:
new 09279029f7 add finstid to print id
09279029f7 is described below
commit 09279029f735cbef01203fdb6aa2302b8bfed2fc
Author: yiguolei <[email protected]>
AuthorDate: Wed Mar 15 16:32:31 2023 +0800
add finstid to print id
---
.../src/main/java/org/apache/doris/qe/ResultReceiver.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiver.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiver.java
index d7c9070421..9923a4e7d2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiver.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ResultReceiver.java
@@ -18,6 +18,7 @@
package org.apache.doris.qe;
import org.apache.doris.common.Status;
+import org.apache.doris.common.util.DebugUtil;
import org.apache.doris.proto.InternalService;
import org.apache.doris.proto.Types;
import org.apache.doris.rpc.BackendServiceProxy;
@@ -96,7 +97,7 @@ public class ResultReceiver {
rowBatch.setQueryStatistics(pResult.getQueryStatistics());
if (packetIdx != pResult.getPacketSeq()) {
- LOG.warn("receive packet failed, expect={}, receive={}",
packetIdx, pResult.getPacketSeq());
+ LOG.warn("finistId={}, receive packet failed, expect={},
receive={}", DebugUtil.printId(finstId), packetIdx, pResult.getPacketSeq());
status.setRpcStatus("receive error packet");
return null;
}
@@ -105,7 +106,7 @@ public class ResultReceiver {
isDone = pResult.getEos();
if (pResult.hasEmptyBatch() && pResult.getEmptyBatch()) {
- LOG.info("get first empty rowbatch");
+ LOG.info("finistId={}, get first empty rowbatch",
DebugUtil.printId(finstId));
rowBatch.setEos(false);
return rowBatch;
} else if (pResult.hasRowBatch() &&
pResult.getRowBatch().size() > 0) {
@@ -119,11 +120,11 @@ public class ResultReceiver {
}
}
} catch (RpcException e) {
- LOG.warn("fetch result rpc exception, finstId={}", finstId, e);
+ LOG.warn("fetch result rpc exception, finstId={}",
DebugUtil.printId(finstId), e);
status.setRpcStatus(e.getMessage());
SimpleScheduler.addToBlacklist(backendId, e.getMessage());
} catch (ExecutionException e) {
- LOG.warn("fetch result execution exception, finstId={}", finstId,
e);
+ LOG.warn("fetch result execution exception, finstId={}",
DebugUtil.printId(finstId), e);
if (e.getMessage().contains("time out")) {
// if timeout, we set error code to TIMEOUT, and it will not
retry querying.
status.setStatus(new Status(TStatusCode.TIMEOUT,
e.getMessage()));
@@ -132,7 +133,7 @@ public class ResultReceiver {
SimpleScheduler.addToBlacklist(backendId, e.getMessage());
}
} catch (TimeoutException e) {
- LOG.warn("fetch result timeout, finstId={}", finstId, e);
+ LOG.warn("fetch result timeout, finstId={}",
DebugUtil.printId(finstId), e);
status.setStatus("query timeout");
} finally {
synchronized (this) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
