Skip to content

Commit 0b21f90

Browse files
committed
fix retry for already finished read
fixes #19182
1 parent 5f596a9 commit 0b21f90

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

ydb/core/kqp/runtime/kqp_stream_lookup_actor.cpp

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -540,7 +540,11 @@ class TKqpStreamLookupActor : public NActors::TActorBootstrapped<TKqpStreamLooku
540540

541541
void Handle(TEvPrivate::TEvRetryRead::TPtr& ev) {
542542
auto readIt = Reads.find(ev->Get()->ReadId);
543-
YQL_ENSURE(readIt != Reads.end(), "Unexpected readId: " << ev->Get()->ReadId);
543+
if (readIt == Reads.end()) {
544+
CA_LOG_D("received retry request for already finished/non-existing read, read_id: " << ev->Get()->ReadId);
545+
return;
546+
}
547+
544548
auto& read = readIt->second;
545549

546550
YQL_ENSURE(read.State != EReadState::Blocked || read.LastSeqNo <= ev->Get()->LastSeqNo);

0 commit comments

Comments
 (0)