This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 f2b502bffba [minor](log) Add debug log in Coordinator (#35936)
f2b502bffba is described below
commit f2b502bffba8781350ad094b6695c5ab131407a6
Author: Gabriel <[email protected]>
AuthorDate: Thu Jun 6 07:38:23 2024 +0800
[minor](log) Add debug log in Coordinator (#35936)
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 2 ++
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 1 +
2 files changed, 3 insertions(+)
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 1f14b6f3b8e..a191de9ba80 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
@@ -1263,6 +1263,8 @@ public class Coordinator implements CoordInterface {
private void cancelRemoteFragmentsAsync(Status cancelReason) {
for (PipelineExecContexts ctx : beToPipelineExecCtxs.values()) {
+ LOG.debug("Cancel query {} on BE {}. Reason: {}",
DebugUtil.printId(queryId), ctx.brpcAddr,
+ cancelReason.toString());
ctx.cancelQuery(cancelReason);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 2a7421616f7..3c1f5a35e8a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -896,6 +896,7 @@ public class StmtExecutor {
if (context.isReturnResultFromLocal()) {
finalizeQuery();
}
+ LOG.debug("Finalize query {}",
DebugUtil.printId(context.queryId()));
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
