From 0a5e9025f91d3cc599b2507c13c011930a22256b Mon Sep 17 00:00:00 2001 From: Nikolay Shestakov Date: Thu, 14 Mar 2024 15:44:37 +0500 Subject: [PATCH] Fixing PartitionChooserActors leaks (#2742) --- .../writer/partition_chooser_impl__abstract_chooser_actor.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h b/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h index 4b385f779cda..0e975c6cec67 100644 --- a/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h +++ b/ydb/core/persqueue/writer/partition_chooser_impl__abstract_chooser_actor.h @@ -207,7 +207,7 @@ class TAbstractPartitionChooserActor: public TActorBootstrapped { TRACE_EVENT(NKikimrServices::PQ_PARTITION_CHOOSER); switch (ev->GetTypeRewrite()) { HFunc(NKqp::TEvKqp::TEvQueryResponse, HandleUpdate); - sFunc(TEvents::TEvPoison, ScheduleStop); + SFunc(TEvents::TEvPoison, TThis::Die); } } @@ -237,7 +237,7 @@ class TAbstractPartitionChooserActor: public TActorBootstrapped { HFunc(NKikimr::TEvPQ::TEvCheckPartitionStatusResponse, Handle); HFunc(TEvTabletPipe::TEvClientConnected, HandleOwnership); HFunc(TEvTabletPipe::TEvClientDestroyed, HandleOwnership); - sFunc(TEvents::TEvPoison, ScheduleStop); + SFunc(TEvents::TEvPoison, TThis::Die); } }