database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[chore](cancel) Make enable_pipeline_task_leakage_detect false by default #40145 (#40192)

Browse Source 
cherry pick from #40145
This commit is contained in:
zhiqiang
2024-08-30 22:48:00 +08:00
committed by GitHub
parent 32a32808a7
commit d949df0c4f
3 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/common/config.cpp
View File

@ -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

2
be/src/common/config.h
View File

@ -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);

5
be/src/runtime/fragment_mgr.cpp
View File

@ -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 {