Skip to content

Commit c8bd4c1

Browse files
committed
fix
1 parent 27a3c6f commit c8bd4c1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/services/persqueue_v1/actors/read_session_actor.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1278,15 +1278,15 @@ void TReadSessionActor<UseMigrationProtocol>::Handle(TEvPersQueue::TEvLockPartit
12781278
}
12791279

12801280
std::unordered_set<ui64> notCommitedToFinishParents;
1281-
for (auto& parent: topic.PartitionGraph->GetPartition(record.GetPartition())->DirectParents) {
1281+
for (auto& parent: partitionNode->DirectParents) {
12821282
for (auto& [_, actorInfo]: Partitions) { // TODO: map
12831283
if (actorInfo.Partition.Partition == parent->Id && !actorInfo.IsLastOffsetCommitted()) {
12841284
notCommitedToFinishParents.emplace(actorInfo.Partition.Partition);
12851285
}
12861286
}
12871287
}
12881288

1289-
const auto& parentPartitions = topic.PartitionGraph->GetPartition(partitionId.Partition)->AllParents;
1289+
const auto& parentPartitions = partitionNode->AllParents;
12901290
const auto database = Request->GetDatabaseName().GetOrElse(AppData(ctx)->PQConfig.GetDatabase());
12911291
const TActorId actorId = ctx.Register(new TPartitionActor(
12921292
ctx.SelfID, ClientId, ClientPath, Cookie, Session, partitionId, record.GetGeneration(),

0 commit comments

Comments
 (0)