Skip to content

Commit 80b03af

Browse files
fix leak in persqueue write session actor (#18226) (#18319)
2 parents dc47c06 + d9a10de commit 80b03af

File tree

2 files changed

+0
-5
lines changed

2 files changed

+0
-5
lines changed

ydb/services/persqueue_v1/actors/write_session_actor.cpp

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1152,8 +1152,6 @@ void TWriteSessionActor<UseMigrationProtocol>::PrepareRequest(THolder<TEvWrite>&
11521152
w->SetSourceId(NPQ::NSourceIdEncoding::EncodeSimple(SourceId));
11531153
}
11541154
w->SetSeqNo(writeRequest.sequence_numbers(messageIndex));
1155-
if (!UseDeduplication)
1156-
SeqNoInflight.push_back(w->GetSeqNo());
11571155

11581156
w->SetCreateTimeMS(writeRequest.created_at_ms(messageIndex));
11591157
w->SetUncompressedSize(writeRequest.blocks_uncompressed_sizes(messageIndex));
@@ -1174,7 +1172,6 @@ void TWriteSessionActor<UseMigrationProtocol>::PrepareRequest(THolder<TEvWrite>&
11741172
w->SetDisableDeduplication(true);
11751173
}
11761174
w->SetSeqNo(msg.seq_no());
1177-
SeqNoInflight.push_back(w->GetSeqNo());
11781175
w->SetCreateTimeMS(::google::protobuf::util::TimeUtil::TimestampToMilliseconds(msg.created_at()));
11791176
w->SetUncompressedSize(msg.uncompressed_size());
11801177
w->SetClientDC(ClientDC);

ydb/services/persqueue_v1/actors/write_session_actor.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -270,8 +270,6 @@ class TWriteSessionActor
270270

271271
TInitRequest InitRequest;
272272

273-
TDeque<ui64> SeqNoInflight;
274-
275273
TActorId PartitionWriterCache;
276274
TActorId PartitionChooser;
277275

0 commit comments

Comments
 (0)