This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new d949df0c4fe [chore](cancel) Make enable_pipeline_task_leakage_detect
false by default #40145 (#40192)
d949df0c4fe is described below
commit d949df0c4fe002e1f2770929b82176ce4c556bc9
Author: zhiqiang <[email protected]>
AuthorDate: Fri Aug 30 22:48:00 2024 +0800
[chore](cancel) Make enable_pipeline_task_leakage_detect false by default
#40145 (#40192)
cherry pick from #40145
---
be/src/common/config.cpp | 2 ++
be/src/common/config.h | 2 ++
be/src/runtime/fragment_mgr.cpp | 5 +++--
3 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp
index 9f5dd9c79d3..2d90d57398a 100644
--- a/be/src/common/config.cpp
+++ b/be/src/common/config.cpp
@@ -1280,6 +1280,8 @@ DEFINE_Validator(tablet_meta_serialize_size_limit,
DEFINE_mInt64(pipeline_task_leakage_detect_period_secs, "60");
+DEFINE_mBool(enable_pipeline_task_leakage_detect, "false");
+
// clang-format off
#ifdef BE_TEST
// test s3
diff --git a/be/src/common/config.h b/be/src/common/config.h
index cb38d1754aa..4b39be5f4c4 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -1365,6 +1365,8 @@ DECLARE_mInt64(tablet_meta_serialize_size_limit);
DECLARE_mInt64(pipeline_task_leakage_detect_period_secs);
+DECLARE_mBool(enable_pipeline_task_leakage_detect);
+
#ifdef BE_TEST
// test s3
DECLARE_String(test_s3_resource);
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index c0c6c52b8cc..57f0e51a2b7 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -1249,8 +1249,9 @@ void FragmentMgr::cancel_worker() {
timespec now_for_check_invalid_query;
clock_gettime(CLOCK_MONOTONIC, &now_for_check_invalid_query);
- if (now_for_check_invalid_query.tv_sec -
check_invalid_query_last_timestamp.tv_sec >
- config::pipeline_task_leakage_detect_period_secs) {
+ if (config::enable_pipeline_task_leakage_detect &&
+ now_for_check_invalid_query.tv_sec -
check_invalid_query_last_timestamp.tv_sec >
+ config::pipeline_task_leakage_detect_period_secs) {
check_invalid_query_last_timestamp = now_for_check_invalid_query;
running_queries_on_all_fes = _get_all_running_queries_from_fe();
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
