Skip to content

Commit

Permalink
[Enhance] Change cpu_limit and mem_limit for default workgroup (#7071)
Browse files Browse the repository at this point in the history
  • Loading branch information
mofeiatwork committed Jun 10, 2022
1 parent daf61c0 commit 8f88ad4
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions be/src/exec/workgroup/work_group.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -314,13 +314,8 @@ bool WorkGroupManager::get_owners_of_scan_worker(int worker_id, WorkGroupPtr run

DefaultWorkGroupInitialization::DefaultWorkGroupInitialization() {
auto default_wg = std::make_shared<WorkGroup>("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<WorkGroup>("wg1", 1, WorkGroup::DEFAULT_VERSION, 2, 0.5, 10, WorkGroupType::WG_NORMAL);
auto wg2 = std::make_shared<WorkGroup>("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) {
Expand Down

0 comments on commit 8f88ad4

Please sign in to comment.