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

[LogFetcher] Adjust ERROR log level

Browse Source
This commit is contained in:
zxlzxlzxlzxlzxl
2024-03-27 08:16:03 +00:00
committed by ob-robot
parent f88ae07971
commit faddfeab96
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp
View File

@ -154,14 +154,22 @@ int ObFsContainerMgr::remove_fsc(const logservice::TenantLSID &tls_id)
ret = OB_NOT_INIT;
LOG_ERROR("ObFsContainerMgr has not be inited");
} else if (OB_FAIL(get_fsc(tls_id, fsc))) {
LOG_ERROR("ObFsContainerMgr get_fsc failed", KR(ret));
if (OB_ENTRY_NOT_EXIST != ret) {
LOG_ERROR("ObFsContainerMgr get_fsc failed", KR(ret));
} else {
LOG_WARN("tls_id not in fsc", K(tls_id));
}
// explicitly call FetchStreamContainer::reset because ObSmallObjPool may not invoke the destructor of the object,
// which cause incorrect destruct order of objects.
} else if (FALSE_IT(fsc->reset())) {
} else if (OB_FAIL(fsc_pool_.free(fsc))) {
LOG_ERROR("fsc_pool_ free failed", KR(ret), K(tls_id), KPC(fsc));
} else if (OB_FAIL(fsc_map_.erase(tls_id))) {
LOG_ERROR("fsc_map_ erase failed", KR(ret), K(tls_id));
if (OB_ENTRY_NOT_EXIST != ret) {
LOG_ERROR("fsc_map_ erase failed", KR(ret), K(tls_id));
} else {
LOG_WARN("tls_id not in fsc_map", K(tls_id));
}
} else {}
return ret;