Skip to content

Commit c39bccc

Browse files
committed
fix
1 parent 2b0adf9 commit c39bccc

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

ydb/services/datastreams/datastreams_proxy.cpp

+2-7
Original file line numberDiff line numberDiff line change
@@ -514,14 +514,9 @@ namespace NKikimr::NDataStreams::V1 {
514514
}
515515

516516
if (!GetProtoRequest()->has_partitioning_settings() ||
517-
518517
(GetProtoRequest()->partitioning_settings().has_auto_partitioning_settings() &&
519-
520-
(GetProtoRequest()->partitioning_settings().auto_partitioning_settings().strategy() ==
521-
Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_DISABLED) ||
522-
523-
(GetProtoRequest()->partitioning_settings().auto_partitioning_settings().strategy() ==
524-
Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_UNSPECIFIED))) {
518+
(GetProtoRequest()->partitioning_settings().auto_partitioning_settings().strategy() == Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_DISABLED) ||
519+
(GetProtoRequest()->partitioning_settings().auto_partitioning_settings().strategy() == Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_UNSPECIFIED))) {
525520

526521
if (!ValidateShardsCount(*GetProtoRequest(), pqGroupDescription, error))
527522
{

0 commit comments

Comments
 (0)