From d949df0c4fe002e1f2770929b82176ce4c556bc9 Mon Sep 17 00:00:00 2001 From: zhiqiang Date: Fri, 30 Aug 2024 22:48:00 +0800 Subject: [PATCH] [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 9f5dd9c79d..2d90d57398 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 cb38d1754a..4b39be5f4c 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 c0c6c52b8c..57f0e51a2b 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 {