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

[Physical Standby] Fix the FetchResultPool alloc failed

Browse Source
This commit is contained in:
obdev
2023-05-09 07:42:04 +00:00
committed by ob-robot
parent 48fcdf2c45
commit 2f527f0595
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/logservice/logfetcher/ob_log_fetch_log_rpc.cpp
View File

@ -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)); LOG_ERROR("init result obj pool fail", KR(ret), K(tenant_id), K(cached_obj_count));
} else { } else {
inited_ = true; inited_ = true;
LOG_INFO("FetchLogARpcResultPool init succ", K(tenant_id), K(cached_obj_count));
} }
return ret; return ret;

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

@ -12,6 +12,7 @@
#define USING_LOG_PREFIX OBLOG_FETCHER #define USING_LOG_PREFIX OBLOG_FETCHER
#include "share/rc/ob_tenant_base.h" // MTL_ID
#include "ob_log_fetch_stream_container_mgr.h" #include "ob_log_fetch_stream_container_mgr.h"
namespace oceanbase namespace oceanbase
@ -61,7 +62,7 @@ int ObFsContainerMgr::init(
LOG_ERROR("init FetchStreamContainer pool fail", KR(ret)); LOG_ERROR("init FetchStreamContainer pool fail", KR(ret));
} else if (OB_FAIL(fs_pool_.init(fetch_stream_cached_count))) { } 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)); 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)); LOG_ERROR("init rpc result pool fail", KR(ret), K(tenant_id), K(rpc_result_cached_count));
} else { } else {
rpc_ = &rpc; rpc_ = &rpc;