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

[CdcService] Return OB_ERR_OUT_OF_LOWER_BOUND when failing to fetch miss log

Browse Source
This commit is contained in:
obdev
2024-02-21 05:46:14 +00:00
committed by ob-robot
parent 2cafbe380d
commit c2289fedc1
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/logservice/cdcservice/ob_cdc_fetcher.cpp
View File

@ -932,22 +932,20 @@ int ObCdcFetcher::do_fetch_missing_log_(const obrpc::ObCdcLSFetchMissLogReq &req
LOG_TRACE("LS fetch a missing log", K(tenant_id_), K(ls_id), K(fetched_log_count), K(frt)); LOG_TRACE("LS fetch a missing log", K(tenant_id_), K(ls_id), K(fetched_log_count), K(frt));
} }
} }
} else if (! (log_fetched_in_palf || log_fetched_in_archive)) {
ret = OB_ERR_OUT_OF_LOWER_BOUND;
LOG_WARN("no log fetched from palf or archive, lower bound", K(log_fetched_in_palf),
K(log_fetched_in_archive), K(missing_lsn), K(idx));
} else {
// failed
} }
} }
} // for } // for
} // else } // else
if (OB_SUCCESS == ret) { if (OB_ITER_END == ret) {
// do nothing
} else if (OB_ITER_END == ret) {
// has iterated to the end of block. // has iterated to the end of block.
ret = OB_SUCCESS; ret = OB_SUCCESS;
} else if (OB_ERR_OUT_OF_LOWER_BOUND == ret) {
// log not exists
ret = OB_SUCCESS;
if (OB_FAIL(handle_log_not_exist_(ls_id, resp))) {
LOG_WARN("handle log_not_exist error", K(ret));
}
} else { } else {
// other error code // other error code
} }