Skip to content

Commit c0f561e

Browse files
authored
do not send request to PartitionActor after finishing of reading (#7214)
1 parent 4b64a05 commit c0f561e

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2419,6 +2419,10 @@ void TPartitionActor::InitLockPartition(const TActorContext& ctx) {
24192419

24202420

24212421
void TPartitionActor::WaitDataInPartition(const TActorContext& ctx) {
2422+
if (ReadingFinishedSent) {
2423+
return;
2424+
}
2425+
24222426
if (WaitDataInfly.size() > 1) { //already got 2 requests inflight
24232427
return;
24242428
}

0 commit comments

Comments
 (0)