From 3af9381c8fe5bbffae40d113149cb07d8cb4a65c Mon Sep 17 00:00:00 2001 From: Nikita Saveliev Date: Mon, 9 Sep 2024 11:22:31 +0000 Subject: [PATCH] Fix CLI max partitions default --- ydb/public/lib/ydb_cli/commands/ydb_service_topic.cpp | 9 ++++++--- ydb/public/lib/ydb_cli/commands/ydb_service_topic.h | 3 +-- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/ydb/public/lib/ydb_cli/commands/ydb_service_topic.cpp b/ydb/public/lib/ydb_cli/commands/ydb_service_topic.cpp index a491332cd983..508d01216463 100644 --- a/ydb/public/lib/ydb_cli/commands/ydb_service_topic.cpp +++ b/ydb/public/lib/ydb_cli/commands/ydb_service_topic.cpp @@ -304,8 +304,7 @@ namespace { config.Opts->AddLongOption("auto-partitioning-max-partitions-count", "Maximum number of partitions for topic") .Optional() - .StoreResult(&MaxActivePartitions_) - .DefaultValue(1); + .StoreResult(&MaxActivePartitions_); AddAutoPartitioning(config, false); } @@ -329,7 +328,11 @@ namespace { GetAutoPartitioningUpUtilizationPercent() ? *GetAutoPartitioningUpUtilizationPercent() : 0, GetAutoPartitioninDownUtilizationPercent() ? *GetAutoPartitioninDownUtilizationPercent() : 0); - settings.PartitioningSettings(MinActivePartitions_, MaxActivePartitions_, autoscaleSettings); + ui32 finalMaxActivePartitions = MaxActivePartitions_.Defined() ? *MaxActivePartitions_ + : autoscaleSettings.GetStrategy() != NTopic::EAutoPartitioningStrategy::Disabled ? MinActivePartitions_ + 50 + : MinActivePartitions_; + + settings.PartitioningSettings(MinActivePartitions_, finalMaxActivePartitions, autoscaleSettings); settings.PartitionWriteBurstBytes(PartitionWriteSpeedKbps_ * 1_KB); settings.PartitionWriteSpeedBytesPerSecond(PartitionWriteSpeedKbps_ * 1_KB); diff --git a/ydb/public/lib/ydb_cli/commands/ydb_service_topic.h b/ydb/public/lib/ydb_cli/commands/ydb_service_topic.h index 2b16a3ea2d4d..3680064f13da 100644 --- a/ydb/public/lib/ydb_cli/commands/ydb_service_topic.h +++ b/ydb/public/lib/ydb_cli/commands/ydb_service_topic.h @@ -71,8 +71,7 @@ namespace NYdb::NConsoleClient { ui64 RetentionPeriodHours_; ui64 RetentionStorageMb_; ui32 MinActivePartitions_; - ui32 MaxActivePartitions_; - + TMaybe MaxActivePartitions_; ui32 PartitionWriteSpeedKbps_; };