From 8f88ad48183006b1d2f878aff0b39b90ae334c0a Mon Sep 17 00:00:00 2001 From: Murphy <96611012+mofeiatwork@users.noreply.github.com> Date: Fri, 10 Jun 2022 16:48:13 +0800 Subject: [PATCH] [Enhance] Change cpu_limit and mem_limit for default workgroup (#7071) --- be/src/exec/workgroup/work_group.cpp | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/be/src/exec/workgroup/work_group.cpp b/be/src/exec/workgroup/work_group.cpp index 9e3427f5f2062..42cf0a795a5f3 100644 --- a/be/src/exec/workgroup/work_group.cpp +++ b/be/src/exec/workgroup/work_group.cpp @@ -314,13 +314,8 @@ bool WorkGroupManager::get_owners_of_scan_worker(int worker_id, WorkGroupPtr run DefaultWorkGroupInitialization::DefaultWorkGroupInitialization() { auto default_wg = std::make_shared("default_wg", WorkGroup::DEFAULT_WG_ID, WorkGroup::DEFAULT_VERSION, 1, - 0.5, 10, WorkGroupType::WG_DEFAULT); - // TODO(by satanson): wg1 and wg2 is just used for test - auto wg1 = std::make_shared("wg1", 1, WorkGroup::DEFAULT_VERSION, 2, 0.5, 10, WorkGroupType::WG_NORMAL); - auto wg2 = std::make_shared("wg2", 2, WorkGroup::DEFAULT_VERSION, 4, 0.5, 10, WorkGroupType::WG_NORMAL); + 1.0, 0, WorkGroupType::WG_DEFAULT); WorkGroupManager::instance()->add_workgroup(default_wg); - WorkGroupManager::instance()->add_workgroup(wg1); - WorkGroupManager::instance()->add_workgroup(wg2); } WorkerOwnerManager::WorkerOwnerManager(int num_total_workers) : _num_total_workers(num_total_workers) {