From fba6aaf2dc523f43166f2c35fde5b6dd50f38a38 Mon Sep 17 00:00:00 2001 From: Konstantin Melekhov Date: Mon, 4 Mar 2024 18:53:22 +0000 Subject: [PATCH] Fix 24-1 quoter crash --- ydb/core/persqueue/partition.cpp | 2 +- ydb/core/persqueue/partition_read.cpp | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ydb/core/persqueue/partition.cpp b/ydb/core/persqueue/partition.cpp index ca2d1443ce4c..5b646acc1c9f 100644 --- a/ydb/core/persqueue/partition.cpp +++ b/ydb/core/persqueue/partition.cpp @@ -996,7 +996,7 @@ void TPartition::Handle(TEvPQ::TEvBlobResponse::TPtr& ev, const TActorContext& c TabletCounters.Cumulative()[COUNTER_PQ_READ_BYTES].Increment(resp->ByteSize()); } ctx.Send(info.Destination != 0 ? Tablet : ctx.SelfID, answer.Event.Release()); - OnReadRequestFinished(cookie, answer.Size, info.User, ctx); + OnReadRequestFinished(info.Destination, answer.Size, info.User, ctx); } void TPartition::Handle(TEvPQ::TEvError::TPtr& ev, const TActorContext& ctx) { diff --git a/ydb/core/persqueue/partition_read.cpp b/ydb/core/persqueue/partition_read.cpp index 7173ebbf2ae2..eae972be6e2c 100644 --- a/ydb/core/persqueue/partition_read.cpp +++ b/ydb/core/persqueue/partition_read.cpp @@ -973,7 +973,7 @@ void TPartition::ProcessRead(const TActorContext& ctx, TReadInfo&& info, const u TabletCounters.Cumulative()[COUNTER_PQ_READ_BYTES].Increment(resp->ByteSize()); ctx.Send(info.Destination != 0 ? Tablet : ctx.SelfID, answer.Event.Release()); - OnReadRequestFinished(cookie, answer.Size, info.User, ctx); + OnReadRequestFinished(info.Destination, answer.Size, info.User, ctx); return; }