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

Fix px dispatch sqc rpc report OB_RPC_CONNECT_ERROR

Browse Source
This commit is contained in:
qianchanger
2021-12-02 14:33:53 +08:00
committed by LINxiansheng
parent 9850c3bc85
commit bdf2dc1ddb
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/px/ob_px_rpc_processor.cpp
View File

@ -356,7 +356,9 @@ void ObDealWithRpcTimeoutCall::deal_with_rpc_timeout_err()
{ {
if (OB_TIMEOUT == ret_) { if (OB_TIMEOUT == ret_) {
int64_t cur_timestamp = ::oceanbase::common::ObTimeUtility::current_time(); int64_t cur_timestamp = ::oceanbase::common::ObTimeUtility::current_time();
if (timeout_ts_ - cur_timestamp > 0) { // 由于存在时间精度不一致导致的时间差, 这里需要满足大于100ms才认为不是超时.
// 一个容错的处理.
if (timeout_ts_ - cur_timestamp > 100 * 1000) {
LOG_DEBUG("rpc return OB_TIMEOUT, but it is actually not timeout, " LOG_DEBUG("rpc return OB_TIMEOUT, but it is actually not timeout, "
"change error code to OB_CONNECT_ERROR", "change error code to OB_CONNECT_ERROR",
K(ret_), K(ret_),