diff --git a/be/src/runtime/task_group/task_group.cpp b/be/src/runtime/task_group/task_group.cpp index 3c5226471585bdf..f8b0c1419c2857d 100644 --- a/be/src/runtime/task_group/task_group.cpp +++ b/be/src/runtime/task_group/task_group.cpp @@ -57,9 +57,10 @@ std::string TaskGroup::debug_string() const { std::shared_lock rl {_mutex}; return fmt::format( "TG[id = {}, name = {}, cpu_share = {}, memory_limit = {}, enable_memory_overcommit = " - "{}, version = {}, cpu_hard_limit = {}]", + "{}, version = {}, cpu_hard_limit = {}, scan_thread_num = {}]", _id, _name, cpu_share(), PrettyPrinter::print(_memory_limit, TUnit::BYTES), - _enable_memory_overcommit ? "true" : "false", _version, cpu_hard_limit()); + _enable_memory_overcommit ? "true" : "false", _version, cpu_hard_limit(), + _scan_thread_num); } void TaskGroup::check_and_update(const TaskGroupInfo& tg_info) { @@ -81,6 +82,7 @@ void TaskGroup::check_and_update(const TaskGroupInfo& tg_info) { _enable_memory_overcommit = tg_info.enable_memory_overcommit; _cpu_share = tg_info.cpu_share; _cpu_hard_limit = tg_info.cpu_hard_limit; + _scan_thread_num = tg_info.scan_thread_num; } else { return; } diff --git a/be/src/runtime/task_group/task_group.h b/be/src/runtime/task_group/task_group.h index 9a6baf49dd8f702..3767731435a6f15 100644 --- a/be/src/runtime/task_group/task_group.h +++ b/be/src/runtime/task_group/task_group.h @@ -134,6 +134,7 @@ class TaskGroup : public std::enable_shared_from_this { std::atomic _cpu_share; std::vector _mem_tracker_limiter_pool; std::atomic _cpu_hard_limit; + std::atomic _scan_thread_num; // means task group is mark dropped // new query can not submit