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

[CdcService] Modify ClientLSCtx state when failed to fetch log in archive

Browse Source
This commit is contained in:
zxlzxlzxlzxlzxl 2024-04-10 03:10:52 +00:00 committed by ob-robot
parent 3429a337ea
commit 054f5a5a80
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -620,6 +620,7 @@ int ObCdcFetcher::ls_fetch_log_(const ObLSID &ls_id,
ret = OB_SUCCESS;
} else if (OB_ALREADY_IN_NOARCHIVE_MODE == ret || OB_ENTRY_NOT_EXIST == ret) {
// archive is not on or lsn less than the start_lsn in archive
ctx.set_fetch_mode(FetchMode::FETCHMODE_ONLINE, "LSReplicaMayMigrate");
ret = OB_ERR_OUT_OF_LOWER_BOUND;
} else {
// other error code, retry because various error code would be returned, retry could fix some problem
@ -631,6 +632,8 @@ int ObCdcFetcher::ls_fetch_log_(const ObLSID &ls_id,
retry_count++;
need_init_iter = true;
ret = OB_SUCCESS;
} else {
ctx.set_fetch_mode(FetchMode::FETCHMODE_ONLINE, "LSReplicaMayMigrate");
}
}
} else { // OB_SUCCESS