Skip to content

Commit a4bdd08

Browse files
authored
fix operator->(): requirement ptr failed (#7084)
1 parent 09fb205 commit a4bdd08

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/core/persqueue/pq_impl.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4553,17 +4553,17 @@ void TPersQueue::Handle(TEvPQ::TEvCheckPartitionStatusRequest::TPtr& ev, const T
45534553
{
45544554
auto& record = ev->Get()->Record;
45554555
auto it = Partitions.find(TPartitionId(TPartitionId(record.GetPartition())));
4556-
if (it == Partitions.end()) {
4556+
if (InitCompleted && it == Partitions.end()) {
45574557
LOG_INFO_S(ctx, NKikimrServices::PERSQUEUE, "Unknown partition " << record.GetPartition());
45584558

4559-
auto response = THolder<TEvPQ::TEvCheckPartitionStatusResponse>();
4559+
auto response = MakeHolder<TEvPQ::TEvCheckPartitionStatusResponse>();
45604560
response->Record.SetStatus(NKikimrPQ::ETopicPartitionStatus::Deleted);
45614561
Send(ev->Sender, response.Release());
45624562

45634563
return;
45644564
}
45654565

4566-
if (it->second.InitDone) {
4566+
if (it != Partitions.end() && it->second.InitDone) {
45674567
Forward(ev, it->second.Actor);
45684568
} else {
45694569
CheckPartitionStatusRequests[record.GetPartition()].push_back(ev);

0 commit comments

Comments
 (0)