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

fix table restore read src lob tenant id wrong

Browse Source
This commit is contained in:
skylhd
2024-01-05 09:17:52 +00:00
committed by ob-robot
parent ba7ce7962f
commit ed17fa678b
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/lob/ob_lob_manager.cpp
View File

@ -1659,6 +1659,7 @@ int ObLobManager::append(ObLobAccessParam& param, ObLobLocatorV2& lob, ObLobMeta
data.assign_buffer(buf + cur_handle_size, append_lob_len); data.assign_buffer(buf + cur_handle_size, append_lob_len);
SMART_VAR(ObLobAccessParam, read_param) { SMART_VAR(ObLobAccessParam, read_param) {
read_param.tx_desc_ = param.tx_desc_; read_param.tx_desc_ = param.tx_desc_;
read_param.tenant_id_ = param.src_tenant_id_;
if (OB_FAIL(build_lob_param(read_param, *param.allocator_, param.coll_type_, if (OB_FAIL(build_lob_param(read_param, *param.allocator_, param.coll_type_,
0, UINT64_MAX, param.timeout_, lob))) { 0, UINT64_MAX, param.timeout_, lob))) {
LOG_WARN("fail to build read param", K(ret), K(lob)); LOG_WARN("fail to build read param", K(ret), K(lob));
@ -1721,6 +1722,7 @@ int ObLobManager::append(ObLobAccessParam& param, ObLobLocatorV2& lob, ObLobMeta
} else { } else {
read_param = new(read_param)ObLobAccessParam(); read_param = new(read_param)ObLobAccessParam();
read_param->tx_desc_ = param.tx_desc_; read_param->tx_desc_ = param.tx_desc_;
read_param->tenant_id_ = param.src_tenant_id_;
if (OB_FAIL(build_lob_param(*read_param, *param.allocator_, param.coll_type_, if (OB_FAIL(build_lob_param(*read_param, *param.allocator_, param.coll_type_,
0, UINT64_MAX, param.timeout_, lob))) { 0, UINT64_MAX, param.timeout_, lob))) {
LOG_WARN("fail to build read param", K(ret), K(lob)); LOG_WARN("fail to build read param", K(ret), K(lob));