Leaking 'PartitionWriterCacheActor` (ydb-platform#4892)

Alek5andr-Kotov · Alek5andr-Kotov · commit 70cb67b10a3c · 2024-05-28T09:42:38.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
@@ -199,6 +199,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
`@@ -199,6 +199,8 @@ void TPartitionWriterCacheActor::Handle(TEvents::TEvPoisonPill::TPtr& ev, const`
`199`	`199`	`for (auto& [_, writer] : Writers) {`
`200`	`200`	`ctx.Send(writer->Actor, new TEvents::TEvPoisonPill());`
`201`	`201`	`}`
	`202`	`+`
	`203`	`+ Die(ctx);`
`202`	`204`	`}`
`203`	`205`
`204`	`206`	`auto TPartitionWriterCacheActor::GetPartitionWriter(const TString& sessionId, const TString& txId,`