Skip to content

Commit 3f27603

Browse files
committed
WIP-35-5-0
1 parent c43511c commit 3f27603

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/tx/schemeshard/schemeshard__operation_incremental_restore_finalize.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ class TIncrementalRestoreFinalizeOp: public TSubOperationWithContext {
164164
// Update the index state to trigger schema sync
165165
NIceDb::TNiceDb db(context.GetDB());
166166
context.SS->Indexes[childPathId]->AlterVersion += 1;
167-
context.SS->PersistTableIndex(db, childPathId);
167+
context.SS->PersistTableIndexAlterVersion(db, childPathId, context.SS->Indexes[childPathId]);
168168

169169
LOG_I("SyncIndexSchemaVersions: Index AlterVersion incremented to "
170170
<< context.SS->Indexes[childPathId]->AlterVersion);
@@ -219,7 +219,7 @@ class TIncrementalRestoreFinalizeOp: public TSubOperationWithContext {
219219
if (context.SS->Indexes.contains(indexPathId)) {
220220
auto oldVersion = context.SS->Indexes[indexPathId]->AlterVersion;
221221
context.SS->Indexes[indexPathId]->AlterVersion += 1;
222-
context.SS->PersistTableIndex(db, indexPathId);
222+
context.SS->PersistTableIndexAlterVersion(db, indexPathId, context.SS->Indexes[indexPathId]);
223223
LOG_I("SyncIndexImplTable: Index AlterVersion incremented from "
224224
<< oldVersion << " to " << context.SS->Indexes[indexPathId]->AlterVersion);
225225
} else {

0 commit comments

Comments
 (0)