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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
