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

improve major freeze performance about cross cluster checksum verification

Browse Source
This commit is contained in:
LiefB
2023-09-01 07:48:17 +00:00
committed by ob-robot
parent cb2055f349
commit d90aeb8241
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/rootserver/freeze/ob_checksum_validator.cpp
View File

@ -826,7 +826,7 @@ int ObCrossClusterTabletChecksumValidator::check_all_table_verification_finished
} else if (stop) {
ret = OB_CANCELED;
LOG_WARN("already stop", KR(ret), K_(tenant_id));
} else {
} else if (need_validate()) { // need to validate cross-cluster checksum
table_count = 0;
ObSchemaGetterGuard schema_guard;
SMART_VARS_2((ObArray<const ObSimpleTableSchemaV2 *>, table_schemas),
@ -853,14 +853,10 @@ int ObCrossClusterTabletChecksumValidator::check_all_table_verification_finished
} else if (cur_compaction_info.is_verified()) { // already finished verification, skip it!
} else if (simple_schema->has_tablet()) {
if (cur_compaction_info.is_index_ckm_verified()) {
if (need_validate()) { // need to validate cross-cluster checksum
if (OB_FAIL(validate_cross_cluster_checksum(stop, frozen_scn, expected_epoch,
simple_schema, table_compaction_map, merge_time_statistics))) {
LOG_WARN("fail to validate cross-cluster checksum", KR(ret), K(stop),
K(frozen_scn), K(expected_epoch), K(table_id));
}
} else { // no need to validate cross-cluster checksum
// do nothing. index validator should already wrote ckm and updated report_scn
if (OB_FAIL(validate_cross_cluster_checksum(stop, frozen_scn, expected_epoch,
simple_schema, table_compaction_map, merge_time_statistics))) {
LOG_WARN("fail to validate cross-cluster checksum", KR(ret), K(stop),
K(frozen_scn), K(expected_epoch), K(table_id));
}
}
} else { // like VIEW that has no tablet, no need to validate cross-cluster checksum
@ -884,6 +880,8 @@ int ObCrossClusterTabletChecksumValidator::check_all_table_verification_finished
}
}
}
} else { // no need to validate cross-cluster checksum
// do nothing. index validator should already wrote ckm and updated report_scn
}
if (OB_CHECKSUM_ERROR == check_ret) {