Skip to content

Commit 852f18a

Browse files
committed
Always leave last schema version even if it is absent in portions
1 parent dba062d commit 852f18a

File tree

1 file changed

+1
-2
lines changed
  • ydb/core/tx/columnshard/normalizer/schema_version

1 file changed

+1
-2
lines changed

ydb/core/tx/columnshard/normalizer/schema_version/version.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@ class TSchemaVersionNormalizer::TNormalizerResult : public INormalizerChanges {
8686
std::vector<INormalizerChanges::TPtr> changes;
8787

8888
{
89-
bool emptyUsed = usedSchemaVersions.size() == 0;
9089
auto rowset = db.Table<Schema::SchemaPresetVersionInfo>().Select();
9190
if (rowset.IsReady()) {
9291
while (!rowset.EndOfSet()) {
@@ -95,7 +94,7 @@ class TSchemaVersionNormalizer::TNormalizerResult : public INormalizerChanges {
9594
Y_ABORT_UNLESS(info.ParseFromString(rowset.GetValue<Schema::SchemaPresetVersionInfo::InfoProto>()));
9695
if (info.HasSchema()) {
9796
ui64 version = info.GetSchema().GetVersion();
98-
if (emptyUsed && ((!maxVersion.has_value()) || (version > maxVersion))) {
97+
if (!maxVersion.has_value() || (version > *maxVersion)) {
9998
maxVersion = version;
10099
}
101100
if (!usedSchemaVersions.contains(version)) {

0 commit comments

Comments
 (0)