[doris] branch master updated: [improvement](exec) add more debug info on fragment exec error (#13899)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 698541e58d [improvement](exec) add more debug info on fragment exec 
error (#13899)
698541e58d is described below

commit 698541e58d4dfc161ee2261342d0b746e879a13c
Author: zhannngchen <48427519+zhannngc...@users.noreply.github.com>
AuthorDate: Fri Nov 4 08:55:31 2022 +0800

    [improvement](exec) add more debug info on fragment exec error (#13899)
---
 be/src/runtime/fragment_mgr.cpp                               | 7 ++++++-
 fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 5 +++--
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 46b8aa44ba..cad45d2468 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -388,6 +388,10 @@ void FragmentExecState::coordinator_callback(const Status& 
status, RuntimeProfil
 
     VLOG_DEBUG << "reportExecStatus params is "
                << apache::thrift::ThriftDebugString(params).c_str();
+    if (!exec_status.ok()) {
+        LOG(WARNING) << "report error status: " << exec_status.to_string()
+                     << " to coordinator: " << _coord_addr;
+    }
     try {
         try {
             coord->reportExecStatus(res, params);
@@ -627,7 +631,8 @@ Status FragmentMgr::exec_plan_fragment(const 
TExecPlanFragmentParams& params, Fi
         fragments_ctx->coord_addr = params.coord;
         LOG(INFO) << "query_id: "
                   << UniqueId(fragments_ctx->query_id.hi, 
fragments_ctx->query_id.lo)
-                  << " coord_addr " << fragments_ctx->coord_addr;
+                  << " coord_addr " << fragments_ctx->coord_addr
+                  << " total fragment num on current host: " << 
params.fragment_num_on_host;
         fragments_ctx->query_globals = params.query_globals;
 
         if (params.__isset.resource_info) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index c066c174d6..2d3f26c170 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -856,8 +856,9 @@ public class Coordinator {
 
             queryStatus.setStatus(status);
             LOG.warn("one instance report fail throw updateStatus(), need 
cancel. job id: {},"
-                            + " query id: {}, instance id: {}",
-                    jobId, DebugUtil.printId(queryId), instanceId != null ? 
DebugUtil.printId(instanceId) : "NaN");
+                            + " query id: {}, instance id: {}, error message: 
{}",
+                    jobId, DebugUtil.printId(queryId), instanceId != null ? 
DebugUtil.printId(instanceId) : "NaN",
+                    status.getErrorMsg());
             cancelInternal(Types.PPlanFragmentCancelReason.INTERNAL_ERROR);
         } finally {
             lock.unlock();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org