From 6c2f3088168b2ef649dc67343ddfd3e3fc1f47e2 Mon Sep 17 00:00:00 2001 From: Hongqin-Li Date: Thu, 7 Dec 2023 02:42:12 +0000 Subject: [PATCH] Add timeout for autoinc rpc --- src/share/ob_tablet_autoincrement_service.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/share/ob_tablet_autoincrement_service.cpp b/src/share/ob_tablet_autoincrement_service.cpp index df94bc1b4..503f42d82 100644 --- a/src/share/ob_tablet_autoincrement_service.cpp +++ b/src/share/ob_tablet_autoincrement_service.cpp @@ -152,7 +152,7 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam ¶m, 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;