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

fix errored index not detected in merge

Browse Source
This commit is contained in:
YoungYang0820
2022-03-28 16:36:58 +08:00
committed by LINxiansheng
parent bd95f35b0c
commit 0f19c37efc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/ob_partition_store.cpp
View File

@ -778,6 +778,7 @@ int ObPartitionStore::get_index_status(const int64_t schema_version, const bool
common::ObIArray<uint64_t> &deleted_and_error_index_ids) common::ObIArray<uint64_t> &deleted_and_error_index_ids)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
UNUSED(is_physical_restore);
share::schema::ObSchemaGetterGuard schema_guard; share::schema::ObSchemaGetterGuard schema_guard;
share::schema::ObMultiVersionSchemaService &schema_service = share::schema::ObMultiVersionSchemaService &schema_service =
share::schema::ObMultiVersionSchemaService::get_instance(); share::schema::ObMultiVersionSchemaService::get_instance();
@ -814,8 +815,7 @@ int ObPartitionStore::get_index_status(const int64_t schema_version, const bool
LOG_WARN("failed to get full tenant schema guard", K(ret), K(fetch_tenant_id), K(pkey_)); LOG_WARN("failed to get full tenant schema guard", K(ret), K(fetch_tenant_id), K(pkey_));
} else if (OB_FAIL(schema_guard.get_schema_version(fetch_tenant_id, latest_schema_version))) { } else if (OB_FAIL(schema_guard.get_schema_version(fetch_tenant_id, latest_schema_version))) {
LOG_WARN("failed to get schema version", K(ret), K(fetch_tenant_id), K(pkey_)); LOG_WARN("failed to get schema version", K(ret), K(fetch_tenant_id), K(pkey_));
} else if (latest_schema_version > save_schema_version || } else if (latest_schema_version >= save_schema_version) {
(is_physical_restore && latest_schema_version >= save_schema_version)) {
// befor check the delete status of index, we should make sure the schema guard is refreshed // befor check the delete status of index, we should make sure the schema guard is refreshed
for (int64_t i = 0; OB_SUCC(ret) && i < index_status.count(); ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < index_status.count(); ++i) {
const share::schema::ObTableSchema *table_schema = NULL; const share::schema::ObTableSchema *table_schema = NULL;