aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authornsofya <nsofya@yandex-team.com>2023-08-05 15:19:05 +0300
committernsofya <nsofya@yandex-team.com>2023-08-05 16:05:08 +0300
commit696e66085c7796be9eb434e93057f927a50f40c0 (patch)
treecfe1037cacad2515c625c8e4ba3a5a8e57e3ad45
parent392403b56a9951b878388b4c0086fdffa02bb1a1 (diff)
downloadydb-696e66085c7796be9eb434e93057f927a50f40c0.tar.gz
Move ttl check
-rw-r--r--ydb/core/tx/columnshard/tables_manager.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/ydb/core/tx/columnshard/tables_manager.cpp b/ydb/core/tx/columnshard/tables_manager.cpp
index 2acde90fb1..56ef733067 100644
--- a/ydb/core/tx/columnshard/tables_manager.cpp
+++ b/ydb/core/tx/columnshard/tables_manager.cpp
@@ -233,6 +233,9 @@ void TTablesManager::AddPresetVersion(const ui32 presetId, const TRowVersion& ve
schemaPreset.AddVersion(version, versionInfo);
if (versionInfo.HasSchema()){
IndexSchemaVersion(version, versionInfo.GetSchema());
+ for (auto& columnName : Ttl.TtlColumns()) {
+ PrimaryIndex->GetVersionedIndex().GetLastSchema()->GetIndexInfo().CheckTtlColumn(columnName);
+ }
}
}
@@ -282,10 +285,6 @@ void TTablesManager::IndexSchemaVersion(const TRowVersion& version, const NKikim
}
PrimaryIndex->UpdateDefaultSchema(snapshot, std::move(indexInfo));
PrimaryIndex->OnTieringModified(nullptr, Ttl);
-
- for (auto& columnName : Ttl.TtlColumns()) {
- PrimaryIndex->GetVersionedIndex().GetLastSchema()->GetIndexInfo().CheckTtlColumn(columnName);
- }
}
NOlap::TIndexInfo TTablesManager::DeserializeIndexInfoFromProto(const NKikimrSchemeOp::TColumnTableSchema& schema) {