diff --git a/ydb/core/persqueue/writer/metadata_initializers.cpp b/ydb/core/persqueue/writer/metadata_initializers.cpp index dff6ade3ada7..b9e3103f59d3 100644 --- a/ydb/core/persqueue/writer/metadata_initializers.cpp +++ b/ydb/core/persqueue/writer/metadata_initializers.cpp @@ -74,6 +74,16 @@ void TSrcIdMetaInitializer::DoPrepare(NInitializer::IInitializerInput::TPtr cont result.emplace_back(new NInitializer::TGenericTableModifier(request, "add_column_SeqNo")); } + + { + Ydb::Table::AlterTableRequest request; + request.set_session_id(""); + request.set_path(tablePath); + request.mutable_alter_partitioning_settings()->set_min_partitions_count(50); + request.mutable_alter_partitioning_settings()->set_partitioning_by_load(::Ydb::FeatureFlag_Status::FeatureFlag_Status_ENABLED); + + result.emplace_back(new NInitializer::TGenericTableModifier(request, "enable_autopartitioning_by_load")); + } } result.emplace_back(NInitializer::TACLModifierConstructor::GetReadOnlyModifier(tablePath, "acl")); controller->OnPreparationFinished(result);