This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit d3b1477edc9b2e02fe9be02f2ce1904530d881f8 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]
