From ffb16dd91fc3ca9aefb8c3af186b0cb0854ce333 Mon Sep 17 00:00:00 2001 From: mw Date: Wed, 16 Jun 2021 13:18:08 +0800 Subject: [PATCH] Fix rs start work related freeze info bug --- src/storage/ob_pg_storage.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/storage/ob_pg_storage.cpp b/src/storage/ob_pg_storage.cpp index 7364f9028..f21363c89 100644 --- a/src/storage/ob_pg_storage.cpp +++ b/src/storage/ob_pg_storage.cpp @@ -7525,8 +7525,12 @@ int ObPGStorage::get_freeze_info_(const common::ObVersion& version, ObFreezeInfo int ret = OB_SUCCESS; freeze_info.reset(); if (OB_FAIL(ObFreezeInfoMgrWrapper::get_instance().get_freeze_info_by_major_version( - pkey_.get_table_id(), version.major_, freeze_info))) { - if (OB_ENTRY_NOT_EXIST == ret) { + pkey_.get_table_id(), + version.major_, + freeze_info))) { + if (OB_ENTRY_NOT_EXIST == ret + || (OB_EAGAIN == ret && OB_ALL_CORE_TABLE_TID == extract_pure_id(pkey_.get_table_id()))) { + LOG_WARN("failed to get freeze info", K(ret), K(pkey_)); ObFreezeInfoSnapshotMgr::FreezeInfoLite freeze_info_lite; if (OB_FAIL(ObFreezeInfoMgrWrapper::get_instance().get_freeze_info_by_major_version( version.major_, freeze_info_lite))) {