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

Retry ddl complement data task during migration

Browse Source
This commit is contained in:
Hongqin-Li
2022-11-18 08:40:05 +00:00
committed by wangzelin.wzl
parent 6c6eaf5dc6
commit 2b92838612
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/ddl/ob_complement_data_task.cpp
View File

@ -219,6 +219,9 @@ int ObComplementDataParam::split_task_ranges(
ranges, ranges,
total_size))) { total_size))) {
LOG_WARN("get multi ranges cost failed", K(ret)); LOG_WARN("get multi ranges cost failed", K(ret));
if (OB_REPLICA_NOT_READABLE == ret) {
ret = OB_EAGAIN;
}
} else if (OB_FALSE_IT(total_size = total_size / 1024 / 1024 /* Byte -> MB */)) { } else if (OB_FALSE_IT(total_size = total_size / 1024 / 1024 /* Byte -> MB */)) {
} else if (OB_FAIL(ObGranuleUtil::compute_total_task_count(params, } else if (OB_FAIL(ObGranuleUtil::compute_total_task_count(params,
total_size, total_size,
@ -230,6 +233,9 @@ int ObComplementDataParam::split_task_ranges(
allocator_, allocator_,
multi_range_split_array))) { multi_range_split_array))) {
LOG_WARN("split multi ranges failed", K(ret)); LOG_WARN("split multi ranges failed", K(ret));
if (OB_REPLICA_NOT_READABLE == ret) {
ret = OB_EAGAIN;
}
} else if (multi_range_split_array.count() <= 0) { } else if (multi_range_split_array.count() <= 0) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected range split arr", K(ret), K(total_size), K(hint_parallelism), LOG_WARN("unexpected range split arr", K(ret), K(total_size), K(hint_parallelism),