[doris] branch opt_dict_perf updated: add finstid to print id

[yiguolei]

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 <yiguo...@gmail.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org