Skip to content

Commit d152b80

Browse files
aavdonkinblinkov
authored andcommitted
Set field Engine to 1 to maintain backward compatibility (#15878)
1 parent 025d46c commit d152b80

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

ydb/core/protos/flat_scheme_op.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -566,6 +566,7 @@ message TColumnTableSchema {
566566
repeated TOlapColumnDescription Columns = 1;
567567
repeated string KeyColumnNames = 2;
568568

569+
optional EColumnTableEngine Engine = 3;
569570
// Internal fields
570571
optional uint32 NextColumnId = 4;
571572

ydb/core/tx/columnshard/tables_manager.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -276,6 +276,7 @@ void TTablesManager::AddSchemaVersion(
276276
it->second = schema;
277277
}
278278

279+
versionInfo.MutableSchema()->SetEngine(NKikimrSchemeOp::COLUMN_ENGINE_REPLACING_TIMESERIES);
279280
Schema::SaveSchemaPresetVersionInfo(db, presetId, version, versionInfo);
280281
if (!PrimaryIndex) {
281282
PrimaryIndex = std::make_unique<NOlap::TColumnEngineForLogs>(TabletId, SchemaObjectsCache, DataAccessorsManager, StoragesManager,

ydb/core/tx/schemeshard/schemeshard_impl.cpp

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3649,8 +3649,12 @@ void TSchemeShard::PersistColumnTable(NIceDb::TNiceDb& db, TPathId pathId, const
36493649

36503650
TString serialized;
36513651
TString serializedSharding;
3652-
Y_ABORT_UNLESS(tableInfo.Description.SerializeToString(&serialized));
3653-
Y_ABORT_UNLESS(tableInfo.Description.GetSharding().SerializeToString(&serializedSharding));
3652+
auto tableInfoCopy = tableInfo;
3653+
if (tableInfo.IsStandalone()) {
3654+
tableInfoCopy.Description.MutableSchema()->SetEngine(NKikimrSchemeOp::COLUMN_ENGINE_REPLACING_TIMESERIES);
3655+
}
3656+
Y_ABORT_UNLESS(tableInfoCopy.Description.SerializeToString(&serialized));
3657+
Y_ABORT_UNLESS(tableInfoCopy.Description.GetSharding().SerializeToString(&serializedSharding));
36543658

36553659
if (isAlter) {
36563660
db.Table<Schema::ColumnTablesAlters>().Key(pathId.LocalPathId).Update(

0 commit comments

Comments
 (0)