Leaking 'PartitionWriterCacheActor` (#4892)

Alek5andr-Kotov · web-flow · commit 6149afe11006 · 2024-05-28T09:36:28.000+03:00
diff --git a/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp b/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp
@@ -204,6 +204,8 @@ void TPartitionWriterCacheActor::Handle(TEvents::TEvPoisonPill::TPtr& ev, const
     for (auto& [_, writer] : Writers) {
         ctx.Send(writer->Actor, new TEvents::TEvPoisonPill());
     }
+
+    Die(ctx);
 }
 
 auto TPartitionWriterCacheActor::GetPartitionWriter(const TString& sessionId, const TString& txId,

Original file line number	Diff line number	Diff line change
`@@ -204,6 +204,8 @@ void TPartitionWriterCacheActor::Handle(TEvents::TEvPoisonPill::TPtr& ev, const`
`204`	`204`	`for (auto& [_, writer] : Writers) {`
`205`	`205`	`ctx.Send(writer->Actor, new TEvents::TEvPoisonPill());`
`206`	`206`	`}`
	`207`	`+`
	`208`	`+ Die(ctx);`
`207`	`209`	`}`
`208`	`210`
`209`	`211`	`auto TPartitionWriterCacheActor::GetPartitionWriter(const TString& sessionId, const TString& txId,`