Skip to content

Commit bf84b49

Browse files
committed
Fix review issues
1 parent f8885bc commit bf84b49

File tree

1 file changed

+12
-6
lines changed

1 file changed

+12
-6
lines changed

ydb/core/tx/schemeshard/schemeshard_export_flow_proposals.cpp

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -246,25 +246,31 @@ THolder<TEvSchemeShard::TEvModifySchemeTransaction> BackupPropose(
246246
idx = parentDescription.GetTable().CdcStreamsSize() + 1;
247247

248248
for (const auto& index : parentDescription.GetTable().GetTableIndexes()) {
249-
if (index.GetName() != indexName) {
250-
++idx;
251-
continue;
252-
}
253-
254249
const TVector<TString> indexColumns(index.GetKeyColumnNames().begin(), index.GetKeyColumnNames().end());
255250
std::optional<Ydb::Table::FulltextIndexSettings::Layout> layout;
256251
if (index.GetType() == NKikimrSchemeOp::EIndexTypeGlobalFulltext) {
257252
const auto& settings = index.GetFulltextIndexDescription().GetSettings();
258253
layout = settings.has_layout() ? settings.layout() : Ydb::Table::FulltextIndexSettings::LAYOUT_UNSPECIFIED;
259254
}
260255

261-
for (const auto& implTable : NTableIndex::GetImplTables(index.GetType(), indexColumns, layout)) {
256+
const auto implTables = NTableIndex::GetImplTables(index.GetType(), indexColumns, layout);
257+
if (index.GetName() != indexName) {
258+
idx += implTables.size();
259+
continue;
260+
}
261+
262+
for (const auto& implTable : implTables) {
262263
if (implTable != implTableName) {
263264
++idx;
264265
continue;
265266
}
266267

267268
found = true;
269+
break;
270+
}
271+
272+
if (found) {
273+
break;
268274
}
269275
}
270276
}

0 commit comments

Comments
 (0)