diff --git a/src/observer/omt/ob_tenant.cpp b/src/observer/omt/ob_tenant.cpp index fe98190574..e0d0677bbe 100644 --- a/src/observer/omt/ob_tenant.cpp +++ b/src/observer/omt/ob_tenant.cpp @@ -336,7 +336,7 @@ int ObResourceGroup::acquire_more_worker(int64_t num, int64_t &succ_num) while (OB_SUCC(ret) && need_num > succ_num) { ObThWorker *w = nullptr; if (OB_FAIL(create_worker(w, tenant_, group_id_, INT32_MAX, this))) { - LOG_ERROR("create worker failed", K(ret)); + LOG_WARN("create worker failed", K(ret)); } else if (!workers_.add_last(&w->worker_node_)) { OB_ASSERT(false); ret = OB_ERR_UNEXPECTED; @@ -1381,7 +1381,7 @@ int ObTenant::acquire_level_worker(int64_t num, int64_t &succ_num, int32_t level while (OB_SUCC(ret) && need_num > succ_num) { ObThWorker *w = nullptr; if (OB_FAIL(create_worker(w, this, 0, level))) { - LOG_ERROR("create worker failed", K(ret)); + LOG_WARN("create worker failed", K(ret)); } else if (!nesting_workers_.add_last(&w->worker_node_)) { OB_ASSERT(false); ret = OB_ERR_UNEXPECTED; @@ -1413,7 +1413,7 @@ int ObTenant::acquire_more_worker(int64_t num, int64_t &succ_num) while (OB_SUCC(ret) && num > succ_num) { ObThWorker *w = nullptr; if (OB_FAIL(create_worker(w, this, 0, 0))) { - LOG_ERROR("create worker failed", K(ret)); + LOG_WARN("create worker failed", K(ret)); } else if (!workers_.add_last(&w->worker_node_)) { OB_ASSERT(false); ret = OB_ERR_UNEXPECTED; diff --git a/src/observer/omt/ob_th_worker.cpp b/src/observer/omt/ob_th_worker.cpp index ed95f73d07..2645ec6ecf 100644 --- a/src/observer/omt/ob_th_worker.cpp +++ b/src/observer/omt/ob_th_worker.cpp @@ -50,8 +50,8 @@ int create_worker(ObThWorker* &worker, ObTenant *tenant, int32_t group_id, { int ret = OB_SUCCESS; if (tenant->total_worker_cnt() >= tenant->max_worker_cnt()) { - ret = OB_SIZE_OVERFLOW; - LOG_ERROR("create worker fail", K(ret), K(tenant->id()), K(group_id), K(level), + ret = OB_RESOURCE_OUT; + LOG_WARN("create worker fail", K(ret), K(tenant->id()), K(group_id), K(level), K(tenant->total_worker_cnt()), K(tenant->max_worker_cnt())); } else if (OB_ISNULL(worker = OB_NEW(ObThWorker, ObMemAttr(0 == GET_TENANT_ID() ? OB_SERVER_TENANT_ID : GET_TENANT_ID(),