merge to stable-24-1: use proper compaction policy for SA tables (#5517)

ydb-platform · Jun 14, 2024 · 7487d61 · 7487d61
1 parent d5bffd8
commit 7487d61
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/ydb/core/statistics/aggregator/tx_init_schema.cpp b/ydb/core/statistics/aggregator/tx_init_schema.cpp
@@ -14,6 +14,17 @@ struct TStatisticsAggregator::TTxInitSchema : public TTxBase {
 
         NIceDb::TNiceDb(txc.DB).Materialize<Schema>();
 
+        static constexpr NIceDb::TTableId bigTableIds[] = {
+            Schema::BaseStats::TableId,
+        };
+
+        for (auto id : bigTableIds) {
+            const auto* tableInfo = txc.DB.GetScheme().GetTableInfo(id);
+            if (!tableInfo || !tableInfo->CompactionPolicy) {
+                txc.DB.Alter().SetCompactionPolicy(id, *NLocalDb::CreateDefaultUserTablePolicy());
+            }
+        }
+
         return true;
     }