From 0f19c37efc4de9b4cfe6a66adcd83738d23c0ab0 Mon Sep 17 00:00:00 2001 From: YoungYang0820 Date: Mon, 28 Mar 2022 16:36:58 +0800 Subject: [PATCH] fix errored index not detected in merge --- src/storage/ob_partition_store.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/storage/ob_partition_store.cpp b/src/storage/ob_partition_store.cpp index c9ba10da62..d0b5f91c72 100644 --- a/src/storage/ob_partition_store.cpp +++ b/src/storage/ob_partition_store.cpp @@ -778,6 +778,7 @@ int ObPartitionStore::get_index_status(const int64_t schema_version, const bool common::ObIArray &deleted_and_error_index_ids) { int ret = OB_SUCCESS; + UNUSED(is_physical_restore); share::schema::ObSchemaGetterGuard schema_guard; share::schema::ObMultiVersionSchemaService &schema_service = 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_)); } 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_)); - } else if (latest_schema_version > save_schema_version || - (is_physical_restore && latest_schema_version >= save_schema_version)) { + } else if (latest_schema_version >= save_schema_version) { // 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) { const share::schema::ObTableSchema *table_schema = NULL; -- GitLab