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 c36a7ca850a [fix](cancel) Fix incorrect cancel (#39737)
c36a7ca850a is described below
commit c36a7ca850a4be4098cdd14c00d5df79b6da8dd6
Author: zhiqiang <[email protected]>
AuthorDate: Thu Aug 22 15:27:24 2024 +0800
[fix](cancel) Fix incorrect cancel (#39737)
fix #39537
---
be/src/runtime/fragment_mgr.cpp | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 2e69bb34152..58bd2681ea7 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -1003,8 +1003,10 @@ void FragmentMgr::cancel_worker() {
itr != running_queries_on_all_fes.end()) {
// Query not found on this frontend, and the query
arrives before the last check
if (itr->second.find(it.first) ==
itr->second.end() &&
- q_ctx->get_query_arrival_timestamp().tv_nsec <
-
check_invalid_query_last_timestamp.tv_nsec &&
+ // tv_nsec represents the number of
nanoseconds that have elapsed since the time point stored in tv_sec.
+ // tv_sec is enough, we do not need to check
tv_nsec.
+ q_ctx->get_query_arrival_timestamp().tv_sec <
+
check_invalid_query_last_timestamp.tv_sec &&
q_ctx->get_query_source() ==
QuerySource::INTERNAL_FRONTEND) {
queries_pipeline_task_leak.push_back(q_ctx->query_id());
LOG_INFO(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
