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

Quick release replay thread for 5188 error

Browse Source
This commit is contained in:
JiahuaChen
2024-04-16 21:46:48 +00:00
committed by ob-robot
parent caf8bc3d4a
commit 5ad7a8b8c4
1 changed files with 15 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/storage/tablet/ob_tablet_create_mds_helper.cpp
View File

@ -270,27 +270,26 @@ int ObTabletCreateMdsHelper::check_create_new_tablets(const obrpc::ObBatchCreate
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (skip_check) { } else if (skip_check) {
} else if (is_truncate) { } else if (is_truncate) {
bool need_wait = false; // for leader, we should use timeout from ddl request
const int64_t timeout = THIS_WORKER.get_timeout_remain(); // for follower, quick failure to release replay thread and other resource like lock
const int64_t timeout = is_replay ? 0 : THIS_WORKER.get_timeout_remain();
const int64_t start_time = ObTimeUtility::fast_current_time(); const int64_t start_time = ObTimeUtility::fast_current_time();
do { do {
if (need_wait) { ret = check_create_new_tablets(arg.get_tablet_count(),
ob_usleep(1000 * 1000L); // sleep 1s is_replay ? ObTabletCreateThrottlingLevel::FREE : ObTabletCreateThrottlingLevel::SOFT);
} if (OB_SUCC(ret)) {
need_wait = false; // do nothing
} else if (OB_UNLIKELY(OB_TOO_MANY_PARTITIONS_ERROR == ret)) {
if (ObTimeUtility::fast_current_time() - start_time >= timeout) { if (ObTimeUtility::fast_current_time() - start_time >= timeout) {
ret = OB_TIMEOUT; ret = OB_TIMEOUT;
LOG_WARN("too many partitions, retry timeout", K(ret)); LOG_WARN("too many partitions, retry timeout", K(ret));
break;
} else if (OB_FAIL(check_create_new_tablets(arg.get_tablet_count(),
is_replay ? ObTabletCreateThrottlingLevel::FREE : ObTabletCreateThrottlingLevel::SOFT))) {
if (OB_TOO_MANY_PARTITIONS_ERROR != ret) {
LOG_WARN("fail to check create new tablets", K(ret));
} else { } else {
need_wait = true; ob_usleep(1000 * 1000L); // sleep 1s
} }
} else {
LOG_WARN("fail to check create new tablets", K(ret));
} }
} while (need_wait); } while (OB_TOO_MANY_PARTITIONS_ERROR == ret);
} else if (OB_FAIL(check_create_new_tablets(arg.get_tablet_count(), } else if (OB_FAIL(check_create_new_tablets(arg.get_tablet_count(),
is_replay ? ObTabletCreateThrottlingLevel::FREE : ObTabletCreateThrottlingLevel::STRICT))) { is_replay ? ObTabletCreateThrottlingLevel::FREE : ObTabletCreateThrottlingLevel::STRICT))) {
LOG_WARN("fail to create new tablets", K(ret)); LOG_WARN("fail to create new tablets", K(ret));