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

adjust log level for direct load.

Browse Source
This commit is contained in:
obdev
2023-03-23 04:41:35 +00:00
committed by ob-robot
parent fdc08f5080
commit b4fc7d1c5f
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/ddl/ob_ddl_heart_beat_task.cpp
View File

@ -104,7 +104,11 @@ int ObDDLHeartBeatTaskContainer::remove_register_task_id(const int64_t task_id)
} else {
ObBucketHashWLockGuard lock_guard(bucket_lock_, task_id);
if (OB_FAIL(register_tasks_.erase_refactored(task_id))) {
LOG_ERROR("remove register task id failed", KR(ret));
if (OB_HASH_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
LOG_WARN("remove register task id failed", KR(ret), K(task_id));
}
}
}
return ret;

6
src/storage/ddl/ob_ddl_server_client.cpp
View File

@ -310,11 +310,7 @@ int ObDDLServerClient::heart_beat_clear(const int64_t task_id)
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret), K(task_id));
} else if (OB_FAIL(OB_DDL_HEART_BEAT_TASK_CONTAINER.remove_register_task_id(task_id))) {
if (OB_HASH_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
LOG_ERROR("failed to remove register task id", K(ret), K(task_id));
}
LOG_WARN("failed to remove register task id", K(ret), K(task_id));
}
return ret;
}