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

[BUGFIX] fix remote lob query timeout

Browse Source
This commit is contained in:
skylhd
2023-08-24 08:40:23 +00:00
committed by ob-robot
parent bb35a1f410
commit aee4962d4b
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3358,10 +3358,14 @@ int ObLobQueryIter::open(ObLobAccessParam &param, common::ObAddr dst_addr)
query_arg_.lob_locator_.ptr_ = param.lob_locator_->ptr_; query_arg_.lob_locator_.ptr_ = param.lob_locator_->ptr_;
query_arg_.lob_locator_.size_ = param.lob_locator_->size_; query_arg_.lob_locator_.size_ = param.lob_locator_->size_;
query_arg_.lob_locator_.has_lob_header_ = param.lob_locator_->has_lob_header_; query_arg_.lob_locator_.has_lob_header_ = param.lob_locator_->has_lob_header_;
int64_t timeout = param.timeout_ - ObTimeUtility::current_time();
if (timeout < ObStorageRpcProxy::STREAM_RPC_TIMEOUT) {
timeout = ObStorageRpcProxy::STREAM_RPC_TIMEOUT;
}
ret = svr_rpc_proxy->to(dst_addr).by(query_arg_.tenant_id_) ret = svr_rpc_proxy->to(dst_addr).by(query_arg_.tenant_id_)
.dst_cluster_id(cluster_id) .dst_cluster_id(cluster_id)
.ratelimit(true).bg_flow(obrpc::ObRpcProxy::BACKGROUND_FLOW) .ratelimit(true).bg_flow(obrpc::ObRpcProxy::BACKGROUND_FLOW)
.timeout(ObStorageRpcProxy::STREAM_RPC_TIMEOUT) .timeout(timeout)
.lob_query(query_arg_, rpc_buffer_, handle_); .lob_query(query_arg_, rpc_buffer_, handle_);
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
LOG_WARN("failed to do remote query", K(ret), K(query_arg_)); LOG_WARN("failed to do remote query", K(ret), K(query_arg_));