From 2eba2d6723df6a81be0acaeceee00b78cfbc052d Mon Sep 17 00:00:00 2001 From: obdev Date: Mon, 17 Jul 2023 09:54:05 +0000 Subject: [PATCH] Modify error num when cdc fetch archive log meet archive delay --- src/logservice/restoreservice/ob_log_archive_piece_mgr.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/logservice/restoreservice/ob_log_archive_piece_mgr.cpp b/src/logservice/restoreservice/ob_log_archive_piece_mgr.cpp index d2a4c41cc3..25a70c791c 100644 --- a/src/logservice/restoreservice/ob_log_archive_piece_mgr.cpp +++ b/src/logservice/restoreservice/ob_log_archive_piece_mgr.cpp @@ -931,9 +931,12 @@ int ObLogArchivePieceContext::get_piece_meta_info_(const int64_t piece_id) bool is_ls_gc = false; palf::LSN min_lsn; palf::LSN max_lsn; - if (piece_id > round_context_.max_piece_id_ || piece_id < round_context_.min_piece_id_) { + if (piece_id < round_context_.min_piece_id_) { ret = OB_INVALID_ARGUMENT; - CLOG_LOG(WARN, "piece id out of round range", K(ret), K(piece_id), KPC(this)); + CLOG_LOG(WARN, "piece id out of round range lower bound", K(ret), K(piece_id), KPC(this)); + } else if (piece_id > round_context_.max_piece_id_) { + ret = OB_ITER_END; + CLOG_LOG(WARN, "piece id out of round range upper bound", K(ret), K(piece_id), KPC(this)); } else if (OB_FAIL(archive_store.init(archive_dest_))) { CLOG_LOG(WARN, "backup store init failed", K(ret), K_(archive_dest)); } else if (OB_FAIL(archive_store.is_single_piece_file_exist(dest_id_, round_id, piece_id, piece_meta_exist))) {