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

Add timeout for autoinc rpc

Browse Source
This commit is contained in:
Hongqin-Li 2024-02-07 12:06:45 +00:00 committed by ob-robot
parent 46b0539baa
commit a774fea87b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/share/ob_tablet_autoincrement_service.cpp
View File

@ -152,7 +152,7 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam &param,
false,/*force_renew*/
leader_addr))) {
LOG_WARN("get leader failed", K(ret), K(arg.ls_id_));
} else if (OB_FAIL(srv_rpc_proxy->to(leader_addr).fetch_tablet_autoinc_seq_cache(arg, res))) {
} else if (OB_FAIL(srv_rpc_proxy->to(leader_addr).timeout(THIS_WORKER.get_timeout_remain()).fetch_tablet_autoinc_seq_cache(arg, res))) {
LOG_WARN("fail to fetch autoinc cache for tablets", K(ret), K(retry_times), K(arg));
} else {
finish = true;