aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorNikolay Shestakov <tesseract@ydb.tech>2024-06-03 13:50:15 +0500
committerGitHub <noreply@github.com>2024-06-03 13:50:15 +0500
commitae64c30bbb54ed4e5703b37129acf86ea5a77656 (patch)
tree0dbf481ebb352e19460e7093ffcb140ed8a47ac0
parent89c3654dc08129116422f621b50086305f68bc9c (diff)
downloadydb-ae64c30bbb54ed4e5703b37129acf86ea5a77656.tar.gz
fix TSchemeShardAllocatePQRebootTest (#5110)
-rw-r--r--ydb/core/persqueue/read_balancer.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/ydb/core/persqueue/read_balancer.cpp b/ydb/core/persqueue/read_balancer.cpp
index cb7d50f19f..fa103152a9 100644
--- a/ydb/core/persqueue/read_balancer.cpp
+++ b/ydb/core/persqueue/read_balancer.cpp
@@ -390,6 +390,7 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvDescribe::TPtr &ev, const T
} else {
THolder<TEvPersQueue::TEvDescribeResponse> res{new TEvPersQueue::TEvDescribeResponse};
res->Record.MutableConfig()->CopyFrom(TabletConfig);
+ res->Record.MutableConfig()->ClearAllPartitions();
res->Record.SetVersion(Version);
res->Record.SetTopicName(Topic);
res->Record.SetPartitionPerTablet(MaxPartsPerTablet);
@@ -457,8 +458,9 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr
ap->SetPartitionId(p.GetPartition());
ap->SetTabletId(p.GetTabletId());
ap->SetCreateVersion(p.GetCreateVersion());
- ap->MutableKeyRange()->SetFromBound(p.GetKeyRange().GetFromBound());
- ap->MutableKeyRange()->SetToBound(p.GetKeyRange().GetToBound());
+ if (p.HasKeyRange()) {
+ ap->MutableKeyRange()->CopyFrom(p.GetKeyRange());
+ }
ap->SetStatus(p.GetStatus());
ap->MutableParentPartitionIds()->Reserve(p.GetParentPartitionIds().size());
for (const auto parent : p.GetParentPartitionIds()) {