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

[CP] ignore OB_PG_PARTITION_NOT_EXIST and OB_PARTITION_NOT_EXIST while building local index

Browse Source
This commit is contained in:
YoungYang0820
2022-05-05 14:17:25 +08:00
committed by wangzelin.wzl
parent 73730a2c0d
commit e2a21af4f1
3 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/storage/ob_build_index_scheduler.cpp
View File

@ -696,7 +696,8 @@ int ObBuildIndexScheduleTask::check_trans_end(bool& is_trans_end, int64_t& snaps
STORAGE_LOG(INFO, "wait trans already end", K(index_id_));
} else if (OB_FAIL(ObPartitionService::get_instance().check_schema_version_elapsed(
pkey_, schema_version_, index_id_, status.snapshot_version_))) {
if (OB_EAGAIN != ret) {
if (OB_EAGAIN != ret && OB_ENTRY_NOT_EXIST != ret && OB_PG_PARTITION_NOT_EXIST != ret &&
OB_PARTITION_NOT_EXIST != ret) {
STORAGE_LOG(WARN, "fail to check schema version eclapsed", K(ret), K(pkey_), K(index_id_));
} else {
ret = OB_SUCCESS;
@ -757,7 +758,7 @@ int ObBuildIndexScheduleTask::check_rs_snapshot_elapsed(const int64_t snapshot_v
STORAGE_LOG(WARN, "fail to wait gts elapse", K(ret), K(pkey_), K(index_id_));
}
} else if (OB_FAIL(ObPartitionService::get_instance().check_ctx_create_timestamp_elapsed(pkey_, snapshot_version))) {
if (OB_EAGAIN == ret) {
if (OB_EAGAIN == ret || OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret || OB_ENTRY_NOT_EXIST) {
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to check ctx create timestmap elapsed", K(ret), K(pkey_), K(index_id_));
@ -823,6 +824,9 @@ int ObBuildIndexScheduleTask::copy_build_index_data(const bool is_leader)
if (OB_ENTRY_NOT_EXIST == ret) {
ret = OB_SUCCESS;
need_copy = true;
} else if (OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret || OB_ENTRY_NOT_EXIST == ret) {
// partition is no longer on this server
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to check replica has major sstable", K(ret), K(pkey_), K(index_id_));
}
@ -1049,7 +1053,7 @@ int ObBuildIndexScheduleTask::get_candidate_source_replica(const bool need_refre
// first check self
if (OB_SUCC(ret) && !candidate_replica_.is_valid()) {
if (OB_FAIL(ObPartitionService::get_instance().check_single_replica_major_sstable_exist(pkey_, index_id_))) {
if (OB_ENTRY_NOT_EXIST != ret) {
if (OB_ENTRY_NOT_EXIST != ret && OB_PG_PARTITION_NOT_EXIST != ret && OB_PARTITION_NOT_EXIST != ret) {
STORAGE_LOG(WARN, "fail to check single replica major sstable exist", K(ret));
} else {
ret = OB_SUCCESS;
@ -1100,7 +1104,11 @@ int ObBuildIndexScheduleTask::check_need_choose_replica(bool& need)
STORAGE_LOG(WARN, "fail to get current build index server", K(ret), K(pkey_), K(index_id_));
}
} else if (OB_FAIL(ObPartitionService::get_instance().get_leader_curr_member_list(pkey_, member_list))) {
STORAGE_LOG(WARN, "fail to get leader current member list", K(ret), K(pkey_), K(index_id_));
if (OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret || OB_ENTRY_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to get leader current member list", K(ret), K(pkey_), K(index_id_));
}
} else if (!member_list.contains(build_index_server)) {
need = true;
}
@ -1234,7 +1242,7 @@ int ObBuildIndexScheduleTask::check_build_index_end(bool& build_index_end, bool&
need_copy = true;
if (need_copy) {
if (OB_FAIL(ObPartitionService::get_instance().check_single_replica_major_sstable_exist(pkey_, index_id_))) {
if (OB_ENTRY_NOT_EXIST == ret) {
if (OB_ENTRY_NOT_EXIST == ret || OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to check replica has major sstable", K(ret), K(pkey_), K(index_id_));
@ -1261,7 +1269,11 @@ int ObBuildIndexScheduleTask::check_build_index_end(bool& build_index_end, bool&
}
if (REACH_TIME_INTERVAL(10 * 1000 * 1000)) {
if (OB_FAIL(ObPartitionService::get_instance().get_curr_member_list(pkey_, member_list))) {
STORAGE_LOG(WARN, "fail to get current member list", K(ret), K(pkey_), K(index_id_));
if (OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret || OB_ENTRY_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to get current member list", K(ret), K(pkey_), K(index_id_));
}
} else if (!member_list.contains(build_index_server)) {
if (OB_FAIL(rollback_state(WAIT_TRANS_END))) {
STORAGE_LOG(WARN, "fail to rollback state", K(ret));
@ -1316,7 +1328,11 @@ int ObBuildIndexScheduleTask::wait_choose_or_build_index_end(const bool is_leade
STORAGE_LOG(WARN, "fail to check need schedule dag", K(ret), K(is_leader), K(pkey_), K(index_id_));
} else if (need_schedule_dag) {
if (OB_FAIL(schedule_dag())) {
STORAGE_LOG(WARN, "fail to schedule dag", K(ret), K(index_id_), K(pkey_));
if (OB_PG_PARTITION_NOT_EXIST == ret || OB_PARTITION_NOT_EXIST == ret || OB_ENTRY_NOT_EXIST == ret) {
ret = OB_SUCCESS;
} else {
STORAGE_LOG(WARN, "fail to schedule dag", K(ret), K(index_id_), K(pkey_));
}
} else {
ObTaskController::get().allow_next_syslog();
STORAGE_LOG(INFO, "schedule build index dag", K(pkey_), K(index_id_));