Skip to content

Commit bfeea6c

Browse files
committed
Revert "Increased min partition count for CDC stream of replication (#21420)"
This reverts commit ae87b17.
1 parent 48e613c commit bfeea6c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -673,8 +673,8 @@ void DoCreatePqPart(
673673
if (AppData()->FeatureFlags.GetEnableTopicAutopartitioningForCDC() && IsReplicationSupportTopicAutopartitioning(op)) {
674674
auto * ps = pqConfig.MutablePartitionStrategy();
675675
ps->SetPartitionStrategyType(::NKikimrPQ::TPQTabletConfig_TPartitionStrategyType::TPQTabletConfig_TPartitionStrategyType_CAN_SPLIT);
676-
ps->SetMinPartitionCount(std::min<ui32>(std::max<ui32>(table->GetPartitions().size() / 16, 1), TSchemeShard::MaxPQGroupPartitionsCount));
677-
ps->SetMaxPartitionCount(std::min<ui32>(std::max<ui32>(table->GetPartitions().size() * 16, 50), TSchemeShard::MaxPQGroupPartitionsCount));
676+
ps->SetMinPartitionCount(1);
677+
ps->SetMaxPartitionCount(std::max<ui32>(table->GetPartitions().size() * 10, 50));
678678
ps->SetScaleThresholdSeconds(30);
679679
} else if (op.GetTopicAutoPartitioning()) {
680680
auto * ps = pqConfig.MutablePartitionStrategy();

0 commit comments

Comments
 (0)