Skip to content

Commit d352144

Browse files
committed
partial of PR ydb-platform#12049
1 parent 389bb3f commit d352144

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

ydb/core/persqueue/partition_write.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1275,6 +1275,11 @@ bool TPartition::ExecRequest(TWriteMsg& p, ProcessParameters& parameters, TEvKey
12751275
++WriteNewMessagesInternal;
12761276
}
12771277

1278+
// Empty partition may will be filling from offset great than zero from mirror actor if source partition old and was clean by retantion time
1279+
if (!Head.GetCount() && !NewHead.GetCount() && DataKeysBody.empty() && HeadKeys.empty() && p.Offset) {
1280+
StartOffset = *p.Offset;
1281+
}
1282+
12781283
TMaybe<TPartData> partData;
12791284
if (p.Msg.TotalParts > 1) { //this is multi-part message
12801285
partData = TPartData(p.Msg.PartNo, p.Msg.TotalParts, p.Msg.TotalSize);

0 commit comments

Comments
 (0)