diff options
| author | Nikolay Shestakov <[email protected]> | 2024-06-03 13:50:15 +0500 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-06-03 13:50:15 +0500 |
| commit | ae64c30bbb54ed4e5703b37129acf86ea5a77656 (patch) | |
| tree | 0dbf481ebb352e19460e7093ffcb140ed8a47ac0 | |
| parent | 89c3654dc08129116422f621b50086305f68bc9c (diff) | |
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 cb7d50f19fe..fa103152a91 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()) { |
