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

[CdcService] Fix CdcSrv Thread exited unexpectedly

Browse Source
This commit is contained in:
obdev 2024-02-10 09:50:01 +00:00 committed by ob-robot
parent 50c294ec8f
commit f31bfbd925
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/logservice/cdcservice/ob_cdc_service.cpp
View File

@ -140,7 +140,7 @@ void ObCdcService::run1()
int64_t last_recycle_ts = 0; int64_t last_recycle_ts = 0;
int64_t last_purge_ts = 0; int64_t last_purge_ts = 0;
int64_t last_check_cdc_read_archive_ts = 0; int64_t last_check_cdc_read_archive_ts = 0;
while(! is_stoped()) { while(! has_set_stop()) {
// archive is always off for sys tenant, no need to query archive dest // archive is always off for sys tenant, no need to query archive dest
int64_t current_ts = ObTimeUtility::current_time(); int64_t current_ts = ObTimeUtility::current_time();
IGNORE_RETURN lib::Thread::update_loop_ts(current_ts); IGNORE_RETURN lib::Thread::update_loop_ts(current_ts);
@ -180,6 +180,8 @@ void ObCdcService::run1()
} }
ob_usleep(static_cast<uint32_t>(BASE_INTERVAL)); ob_usleep(static_cast<uint32_t>(BASE_INTERVAL));
} }
EXTLOG_LOG(INFO, "CdcSrv Thread Exit due to has_set_stop", "stop_flag", has_set_stop());
} }
} }