diff --git a/src/share/schema/ob_dependency_info.cpp b/src/share/schema/ob_dependency_info.cpp index 1fc60b100d..e351f60e0d 100644 --- a/src/share/schema/ob_dependency_info.cpp +++ b/src/share/schema/ob_dependency_info.cpp @@ -301,7 +301,7 @@ int ObDependencyInfo::insert_schema_object_dependency(common::ObISQLClient &tran if (!only_history) { ObDMLExecHelper exec(trans, exec_tenant_id); 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)); } } else { @@ -309,7 +309,7 @@ int ObDependencyInfo::insert_schema_object_dependency(common::ObISQLClient &tran 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; LOG_WARN("affected_rows unexpected to be one", K(affected_rows), K(ret)); } diff --git a/src/sql/executor/ob_maintain_dependency_info_task.cpp b/src/sql/executor/ob_maintain_dependency_info_task.cpp index f1161e0767..92a7ab2adc 100644 --- a/src/sql/executor/ob_maintain_dependency_info_task.cpp +++ b/src/sql/executor/ob_maintain_dependency_info_task.cpp @@ -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 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)); } else if (OB_FAIL(view_info_set_.create(INIT_BKT_SIZE))) { LOG_WARN("failed to init view set", K(ret));