Skip to content

Commit 7e21f33

Browse files
authored
Fix warning (#9274)
1 parent af476a9 commit 7e21f33

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

ydb/core/persqueue/partition_read.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1001,7 +1001,9 @@ void TPartition::ProcessRead(const TActorContext& ctx, TReadInfo&& info, const u
10011001
ctx, EndOffset, Partition, &UsersInfoStorage->GetOrCreate(info.User, ctx),
10021002
info.Destination, GetSizeLag(info.Offset), Tablet, Config.GetMeteringMode()
10031003
));
1004-
const auto& resp = dynamic_cast<TEvPQ::TEvProxyResponse*>(answer.Event.Get())->Response;
1004+
const auto* ev = dynamic_cast<TEvPQ::TEvProxyResponse*>(answer.Event.Get());
1005+
Y_ABORT_UNLESS(ev);
1006+
const auto& resp = ev->Response;
10051007
if (info.IsSubscription) {
10061008
TabletCounters.Cumulative()[COUNTER_PQ_READ_SUBSCRIPTION_OK].Increment(1);
10071009
}

0 commit comments

Comments
 (0)