hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix create synonym 4016 && add thread name for maintain dep task queue

Browse Source
This commit is contained in:
obdev
2023-02-24 13:24:59 +00:00
committed by ob-robot
parent 74f60222a8
commit 0e8e04f3d3
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/share/schema/ob_dependency_info.cpp
View File

@ -301,7 +301,7 @@ int ObDependencyInfo::insert_schema_object_dependency(common::ObISQLClient &tran
if (!only_history) { if (!only_history) {
ObDMLExecHelper exec(trans, exec_tenant_id); ObDMLExecHelper exec(trans, exec_tenant_id);
if (is_replace) { if (is_replace) {
if (OB_FAIL(exec.exec_update(OB_ALL_TENANT_DEPENDENCY_TNAME, dml, affected_rows))) { if (OB_FAIL(exec.exec_insert_update(OB_ALL_TENANT_DEPENDENCY_TNAME, dml, affected_rows))) {
LOG_WARN("execute update failed", K(ret)); LOG_WARN("execute update failed", K(ret));
} }
} else { } else {
@ -309,7 +309,7 @@ int ObDependencyInfo::insert_schema_object_dependency(common::ObISQLClient &tran
LOG_WARN("execute insert failed", K(ret)); LOG_WARN("execute insert failed", K(ret));
} }
} }
if (OB_SUCC(ret) && !is_single_row(affected_rows)) { if (OB_SUCC(ret) && !is_single_row(affected_rows) && !is_double_row(affected_rows)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("affected_rows unexpected to be one", K(affected_rows), K(ret)); LOG_WARN("affected_rows unexpected to be one", K(affected_rows), K(ret));
} }

2
src/sql/executor/ob_maintain_dependency_info_task.cpp
View File

@ -194,7 +194,7 @@ int ObMaintainObjDepInfoTask::assign_view_schema(const ObTableSchema &view_schem
int ObMaintainDepInfoTaskQueue::init(const int64_t thread_cnt, const int64_t queue_size) int ObMaintainDepInfoTaskQueue::init(const int64_t thread_cnt, const int64_t queue_size)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_FAIL(ObAsyncTaskQueue::init(thread_cnt, queue_size))) { if (OB_FAIL(ObAsyncTaskQueue::init(thread_cnt, queue_size, "MaintainDepInfoTaskQueue"))) {
LOG_WARN("failed to init base queue", K(ret)); LOG_WARN("failed to init base queue", K(ret));
} else if (OB_FAIL(view_info_set_.create(INIT_BKT_SIZE))) { } else if (OB_FAIL(view_info_set_.create(INIT_BKT_SIZE))) {
LOG_WARN("failed to init view set", K(ret)); LOG_WARN("failed to init view set", K(ret));