diff --git a/src/logservice/logfetcher/ob_log_fetch_log_rpc.cpp b/src/logservice/logfetcher/ob_log_fetch_log_rpc.cpp index 6cd9a16292..e140e3325b 100644 --- a/src/logservice/logfetcher/ob_log_fetch_log_rpc.cpp +++ b/src/logservice/logfetcher/ob_log_fetch_log_rpc.cpp @@ -1363,6 +1363,7 @@ int FetchLogARpcResultPool::init(const uint64_t tenant_id, const int64_t cached_ LOG_ERROR("init result obj pool fail", KR(ret), K(tenant_id), K(cached_obj_count)); } else { inited_ = true; + LOG_INFO("FetchLogARpcResultPool init succ", K(tenant_id), K(cached_obj_count)); } return ret; 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 96fabd54a8..1f79980a81 100644 --- a/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp +++ b/src/logservice/logfetcher/ob_log_fetch_stream_container_mgr.cpp @@ -12,6 +12,7 @@ #define USING_LOG_PREFIX OBLOG_FETCHER +#include "share/rc/ob_tenant_base.h" // MTL_ID #include "ob_log_fetch_stream_container_mgr.h" namespace oceanbase @@ -61,7 +62,7 @@ int ObFsContainerMgr::init( LOG_ERROR("init FetchStreamContainer pool fail", KR(ret)); } else if (OB_FAIL(fs_pool_.init(fetch_stream_cached_count))) { LOG_ERROR("init fetch stream pool fail", KR(ret), K(fetch_stream_cached_count)); - } else if (OB_FAIL(rpc_result_pool_.init(tenant_id, rpc_result_cached_count))) { + } else if (OB_FAIL(rpc_result_pool_.init(MTL_ID(), rpc_result_cached_count))) { LOG_ERROR("init rpc result pool fail", KR(ret), K(tenant_id), K(rpc_result_cached_count)); } else { rpc_ = &rpc;