We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 5f596a9 + 0b21f90 commit 30b1a69Copy full SHA for 30b1a69
ydb/core/kqp/runtime/kqp_stream_lookup_actor.cpp
@@ -540,7 +540,11 @@ class TKqpStreamLookupActor : public NActors::TActorBootstrapped<TKqpStreamLooku
540
541
void Handle(TEvPrivate::TEvRetryRead::TPtr& ev) {
542
auto readIt = Reads.find(ev->Get()->ReadId);
543
- YQL_ENSURE(readIt != Reads.end(), "Unexpected readId: " << ev->Get()->ReadId);
+ 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
+
548
auto& read = readIt->second;
549
550
YQL_ENSURE(read.State != EReadState::Blocked || read.LastSeqNo <= ev->Get()->LastSeqNo);
0 commit comments