Skip to content

Commit 107587f

Browse files
FloatingCrowbarblinkov
authored andcommitted
Fix the bug on pipe failure in read proxy (#15439)
1 parent 1a80058 commit 107587f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/services/persqueue_v1/actors/partition_actor.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1305,12 +1305,12 @@ void TPartitionActor::Handle(TEvPQProxy::TEvRead::TPtr& ev, const TActorContext&
13051305
const auto req = ev->Get();
13061306

13071307
auto request = MakeReadRequest(ReadOffset, 0, req->MaxCount, req->MaxSize, req->MaxTimeLagMs, req->ReadTimestampMs, DirectReadId);
1308-
1308+
RequestInfly = true;
1309+
CurrentRequest = request;
1310+
13091311
if (!PipeClient) //Pipe will be recreated soon
13101312
return;
13111313

1312-
RequestInfly = true;
1313-
CurrentRequest = request;
13141314
TAutoPtr<TEvPersQueue::TEvRequest> event(new TEvPersQueue::TEvRequest);
13151315
event->Record.Swap(&request);
13161316

0 commit comments

Comments
 (0)