Skip to content

Commit 74a9fd5

Browse files
authored
fix LockedPartitions without session (#7736)
1 parent 12a1ece commit 74a9fd5

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ydb/core/persqueue/read_balancer__balancing.cpp

+3-2
Original file line numberDiff line numberDiff line change
@@ -284,6 +284,8 @@ void TPartitionFamily::AfterRelease() {
284284
Partitions.clear();
285285
Partitions.insert(Partitions.end(), RootPartitions.begin(), RootPartitions.end());
286286

287+
LockedPartitions.clear();
288+
287289
ClassifyPartitions();
288290
UpdatePartitionMapping(Partitions);
289291
// After reducing the number of partitions in the family, the list of reading sessions that can read this family may expand.
@@ -1783,10 +1785,9 @@ void TBalancer::Handle(TEvPersQueue::TEvGetReadSessionsInfo::TPtr& ev, const TAc
17831785
pi->SetPartition(partitionId);
17841786

17851787
auto* family = consumer->FindFamily(partitionId);
1786-
if (family && family->LockedPartitions.contains(partitionId)) {
1788+
if (family && family->Session && family->LockedPartitions.contains(partitionId)) {
17871789
auto* session = family->Session;
17881790

1789-
Y_ABORT_UNLESS(session != nullptr);
17901791
pi->SetClientNode(session->ClientNode);
17911792
pi->SetProxyNodeId(session->ProxyNodeId);
17921793
pi->SetSession(session->SessionName);

0 commit comments

Comments
 (0)