diff options
| author | Nikolay Shestakov <tesseract@ydb.tech> | 2024-08-17 18:14:56 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-17 18:14:56 +0500 |
| commit | a61f9c3a007b65acb5144c3ff1aff7f05c9d4a3d (patch) | |
| tree | 75ff3841d053650fc1b7881440d7542eb19c96c5 | |
| parent | aef62c20820849e4e62414ab890907e34f2f232a (diff) | |
| download | ydb-a61f9c3a007b65acb5144c3ff1aff7f05c9d4a3d.tar.gz | |
fix frozing of write session (#7959)
| -rw-r--r-- | ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h b/ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h index 33e1f3dd278..0b89f1e2039 100644 --- a/ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h +++ b/ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h @@ -100,6 +100,7 @@ private: TRACE_EVENT(NKikimrServices::PQ_PARTITION_CHOOSER); switch (ev->GetTypeRewrite()) { HFunc(TEvPersQueue::TEvGetPartitionIdForWriteResponse, Handle); + HFunc(TEvTabletPipe::TEvClientConnected, Handle); HFunc(TEvTabletPipe::TEvClientDestroyed, Handle); SFunc(TEvents::TEvPoison, TThis::Die); } |