File tree Expand file tree Collapse file tree 2 files changed +0
-5
lines changed
ydb/services/persqueue_v1/actors Expand file tree Collapse file tree 2 files changed +0
-5
lines changed Original file line number Diff line number Diff 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);
Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments