[chore](cancel) Make enable_pipeline_task_leakage_detect false by def…

…ault (apache#40145) add be.conf enable_pipeline_task_leakage_detect, default to false.
wyxxxcat · Aug 30, 2024 · 721d460 · 721d460
1 parent d580a0a
commit 721d460
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp
@@ -1320,6 +1320,8 @@ DEFINE_mInt64(pipeline_task_leakage_detect_period_secs, "60");
 DEFINE_mInt32(snappy_compression_block_size, "262144");
 DEFINE_mInt32(lz4_compression_block_size, "262144");
 
+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
@@ -1414,6 +1414,8 @@ DECLARE_mInt64(pipeline_task_leakage_detect_period_secs);
 DECLARE_mInt32(snappy_compression_block_size);
 DECLARE_mInt32(lz4_compression_block_size);
 
+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
@@ -951,8 +951,9 @@ void FragmentMgr::cancel_worker() {
         timespec now;
         clock_gettime(CLOCK_MONOTONIC, &now);
 
-        if (now.tv_sec - check_invalid_query_last_timestamp.tv_sec >
-            config::pipeline_task_leakage_detect_period_secs) {
+        if (config::enable_pipeline_task_leakage_detect &&
+            now.tv_sec - check_invalid_query_last_timestamp.tv_sec >
+                    config::pipeline_task_leakage_detect_period_secs) {
             check_invalid_query_last_timestamp = now;
             running_queries_on_all_fes = _get_all_running_queries_from_fe();
         } else {