diff options
author | Nikolay Shestakov <tesseract@ydb.tech> | 2024-06-03 13:50:15 +0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-06-03 13:50:15 +0500 |
commit | ae64c30bbb54ed4e5703b37129acf86ea5a77656 (patch) | |
tree | 0dbf481ebb352e19460e7093ffcb140ed8a47ac0 | |
parent | 89c3654dc08129116422f621b50086305f68bc9c (diff) | |
download | ydb-ae64c30bbb54ed4e5703b37129acf86ea5a77656.tar.gz |
fix TSchemeShardAllocatePQRebootTest (#5110)
-rw-r--r-- | ydb/core/persqueue/read_balancer.cpp | 6 |
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()) { |