Skip to content

Commit b6b8a16

Browse files
committed
fix
1 parent 0c9e5b1 commit b6b8a16

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/persqueue/partition_write.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1257,8 +1257,8 @@ bool TPartition::ExecRequest(TWriteMsg& p, ProcessParameters& parameters, TEvKey
12571257
}
12581258

12591259
// Empty partition may will be filling from offset great than zero from mirror actor if source partition old and was clean by retantion time
1260-
if (!Head.GetCount() && !NewHead.GetCount() && DataKeysBody.empty() && HeadKeys.empty()) {
1261-
StartOffset = curOffset;
1260+
if (!Head.GetCount() && !NewHead.GetCount() && DataKeysBody.empty() && HeadKeys.empty() && p.Offset) {
1261+
StartOffset = *p.Offset;
12621262
}
12631263

12641264
TMaybe<TPartData> partData;

0 commit comments

Comments
 (0)