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

add unique index checking retry

Browse Source
This commit is contained in:
Charles0429
2022-12-15 13:15:26 +00:00
committed by ob-robot
parent c91594425b
commit a8e878a7bc
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/rootserver/ddl_task/ob_ddl_single_replica_executor.cpp
View File

@ -221,7 +221,7 @@ int ObDDLSingleReplicaExecutor::set_partition_task_status(const common::ObTablet
if (OB_SUCCESS == ret_code) { if (OB_SUCCESS == ret_code) {
build_infos.at(i).ret_code_ = OB_SUCCESS; build_infos.at(i).ret_code_ = OB_SUCCESS;
build_infos.at(i).stat_ = ObPartitionBuildStat::BUILD_SUCCEED; build_infos.at(i).stat_ = ObPartitionBuildStat::BUILD_SUCCEED;
} else if (ObIDDLTask::in_ddl_retry_white_list(ret_code) || OB_REPLICA_NOT_READABLE == ret_code || OB_ERR_INSUFFICIENT_PX_WORKER == ret_code) { } else if (ObIDDLTask::in_ddl_retry_white_list(ret_code)) {
build_infos.at(i).ret_code_ = OB_SUCCESS; build_infos.at(i).ret_code_ = OB_SUCCESS;
build_infos.at(i).stat_ = ObPartitionBuildStat::BUILD_RETRY; build_infos.at(i).stat_ = ObPartitionBuildStat::BUILD_RETRY;
} else { } else {

2
src/rootserver/ddl_task/ob_ddl_task.cpp
View File

@ -1325,7 +1325,7 @@ int ObDDLWaitColumnChecksumCtx::update_status(const common::ObTabletID &tablet_i
found = true; found = true;
if (OB_SUCCESS == ret_code) { if (OB_SUCCESS == ret_code) {
item.col_checksum_stat_ = ColChecksumStat::CCS_SUCCEED; item.col_checksum_stat_ = ColChecksumStat::CCS_SUCCEED;
} else if (OB_NOT_MASTER == ret_code || OB_PARTITION_NOT_EXIST == ret_code) { } else if (ObIDDLTask::in_ddl_retry_white_list(ret_code)) {
item.col_checksum_stat_ = CCS_NOT_MASTER; item.col_checksum_stat_ = CCS_NOT_MASTER;
} else { } else {
item.col_checksum_stat_ = CCS_FAILED; item.col_checksum_stat_ = CCS_FAILED;

2
src/share/ob_ddl_task_executor.h
View File

@ -79,7 +79,7 @@ private:
|| common::OB_ERR_REMOTE_SCHEMA_NOT_FULL == ret_code || common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret_code || common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret_code || common::OB_ERR_REMOTE_SCHEMA_NOT_FULL == ret_code || common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret_code || common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret_code
|| common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT_NOWAIT == ret_code || common::OB_TRANS_STMT_NEED_RETRY == ret_code || common::OB_SCHEMA_NOT_UPTODATE == ret_code || common::OB_ERR_EXCLUSIVE_LOCK_CONFLICT_NOWAIT == ret_code || common::OB_TRANS_STMT_NEED_RETRY == ret_code || common::OB_SCHEMA_NOT_UPTODATE == ret_code
|| common::OB_TRANSACTION_SET_VIOLATION == ret_code || common::OB_TRANS_CANNOT_SERIALIZE == ret_code || common::OB_GTI_NOT_READY == ret_code || common::OB_TRANSACTION_SET_VIOLATION == ret_code || common::OB_TRANS_CANNOT_SERIALIZE == ret_code || common::OB_GTI_NOT_READY == ret_code
|| common::OB_TRANS_WEAK_READ_VERSION_NOT_READY == ret_code || common::OB_REPLICA_NOT_READABLE == ret_code; || common::OB_TRANS_WEAK_READ_VERSION_NOT_READY == ret_code || common::OB_REPLICA_NOT_READABLE == ret_code || common::OB_ERR_INSUFFICIENT_PX_WORKER == ret_code;
} }
static bool is_not_exist(const int ret_code) { static bool is_not_exist(const int ret_code) {
return common::OB_LS_NOT_EXIST == ret_code || common::OB_TABLET_NOT_EXIST == ret_code || common::OB_TENANT_NOT_EXIST == ret_code return common::OB_LS_NOT_EXIST == ret_code || common::OB_TABLET_NOT_EXIST == ret_code || common::OB_TENANT_NOT_EXIST == ret_code