[BUGFIX] fix lob rpc iter not free

This commit is contained in:
obdev
2023-02-24 15:23:09 +00:00
committed by ob-robot
parent ca5932873a
commit 0b3f5231c5

View File

@ -1676,7 +1676,7 @@ int ObLobQueryP::process_read()
ObLobAccessParam param;
param.scan_backward_ = arg_.scan_backward_;
param.from_rpc_ = true;
ObLobQueryIter *iter;
ObLobQueryIter *iter = nullptr;
if (OB_FAIL(lob_mngr->build_lob_param(param, allocator_, arg_.cs_type_, arg_.offset_,
arg_.len_, ObStorageRpcProxy::STREAM_RPC_TIMEOUT, arg_.lob_locator_))) {
LOG_WARN("failed to build lob param", K(ret));
@ -1704,6 +1704,10 @@ int ObLobQueryP::process_read()
ret = OB_SUCCESS;
}
}
if (OB_NOT_NULL(iter)) {
iter->reset();
common::sop_return(ObLobQueryIter, iter);
}
}
return ret;
}