aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlek5andr-Kotov <akotov@ydb.tech>2025-07-04 20:40:37 +0300
committerGitHub <noreply@github.com>2025-07-04 17:40:37 +0000
commitc59858d7f52ea791b46ea7fdb99c663c1044fbff (patch)
tree41cd81736c8d249662de76450cea75806fbbf005
parent3170fe5f46a7d3d6d11961042ac2b831a8a7af6e (diff)
downloadydb-main.tar.gz
The `TEvPQProxy::TEvAuthResultOk` handler crashes (#20638)HEADmain
-rw-r--r--ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp
index 8f356504736..f6aa09ebf0d 100644
--- a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp
+++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp
@@ -979,6 +979,9 @@ void TReadSessionActor::Handle(V1::TEvPQProxy::TEvAuthResultOk::TPtr& ev, const
for (auto& [name, t] : ev->Get()->TopicAndTablets) {
auto& topicHolder = Topics[t.TopicNameConverter->GetInternalName()];
+ if (!topicHolder) {
+ topicHolder = std::make_shared<TTopicHolder>();
+ }
topicHolder->TabletID = t.TabletID;
topicHolder->CloudId = t.CloudId;
topicHolder->DbId = t.DbId;