diff --git a/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp b/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp index 55ce849f77..653f3b52b4 100644 --- a/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp +++ b/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp @@ -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;