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

fix repeatable ddl start when migrate retry

Browse Source
This commit is contained in:
simonjoylet
2022-11-22 03:35:57 +00:00
committed by wangzelin.wzl
parent f61eb3f967
commit 5ea836facc
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/ddl/ob_tablet_ddl_kv_mgr.cpp
View File

@ -107,12 +107,15 @@ int ObTabletDDLKvMgr::ddl_start(const ObITable::TableKey &table_key,
ret = OB_ERR_SYS; ret = OB_ERR_SYS;
LOG_WARN("tablet id not same", K(ret), K(table_key), K(tablet_id_)); LOG_WARN("tablet id not same", K(ret), K(table_key), K(tablet_id_));
} else if (0 != start_log_ts_) { } else if (0 != start_log_ts_) {
if (execution_id >= execution_id_ && start_log_ts > start_log_ts_) { if (execution_id >= execution_id_ && start_log_ts >= start_log_ts_) {
LOG_INFO("execution id changed, need cleanup", K(ls_id_), K(tablet_id_), K(execution_id_), K(execution_id), K(start_log_ts_), K(start_log_ts)); LOG_INFO("execution id changed, need cleanup", K(ls_id_), K(tablet_id_), K(execution_id_), K(execution_id), K(start_log_ts_), K(start_log_ts));
cleanup_unlock(); cleanup_unlock();
is_brand_new = true; is_brand_new = true;
} else { } else {
if (checkpoint_log_ts <= 0) {
// only return error code when not start from checkpoint.
ret = OB_TASK_EXPIRED; ret = OB_TASK_EXPIRED;
}
LOG_INFO("ddl start ignored", K(ls_id_), K(tablet_id_), K(execution_id_), K(execution_id), K(start_log_ts_), K(start_log_ts)); LOG_INFO("ddl start ignored", K(ls_id_), K(tablet_id_), K(execution_id_), K(execution_id), K(start_log_ts_), K(start_log_ts));
} }
} else { } else {