From 0c22a02c2b131520e9ff59762e4f7ee871eee6bc Mon Sep 17 00:00:00 2001 From: Hongqin-Li Date: Mon, 14 Aug 2023 10:12:33 +0000 Subject: [PATCH] Retry for OB_LS_NOT_EXIST and OB_TABLET_NOT_EXIST when fetching tablet autoinc --- src/share/ob_tablet_autoincrement_service.cpp | 2 +- src/share/ob_tablet_autoincrement_service.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/share/ob_tablet_autoincrement_service.cpp b/src/share/ob_tablet_autoincrement_service.cpp index d501cfe14..7d70f1917 100644 --- a/src/share/ob_tablet_autoincrement_service.cpp +++ b/src/share/ob_tablet_autoincrement_service.cpp @@ -160,7 +160,7 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam ¶m, finish = true; } if (OB_FAIL(ret) && is_retryable(ret)) { - const bool need_refresh_leader = OB_NOT_MASTER == ret; + const bool need_refresh_leader = OB_NOT_MASTER == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret; ob_usleep(RETRY_INTERVAL); res.reset(); if (OB_FAIL(THIS_WORKER.check_status())) { // overwrite ret diff --git a/src/share/ob_tablet_autoincrement_service.h b/src/share/ob_tablet_autoincrement_service.h index c42f55052..9a057fd23 100644 --- a/src/share/ob_tablet_autoincrement_service.h +++ b/src/share/ob_tablet_autoincrement_service.h @@ -80,7 +80,7 @@ private: } bool is_retryable(int ret) { - return OB_NOT_MASTER == ret || OB_NOT_INIT == ret || OB_TIMEOUT == ret || OB_EAGAIN == ret; + return OB_NOT_MASTER == ret || OB_NOT_INIT == ret || OB_TIMEOUT == ret || OB_EAGAIN == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret; } private: static const int64_t PREFETCH_THRESHOLD = 4;