Skip to content

Commit e7ff52a

Browse files
[/] deleted the check
1 parent 3750f48 commit e7ff52a

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

ydb/core/persqueue/partition_init.cpp

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -488,15 +488,6 @@ void TInitDataRangeStep::Handle(TEvKeyValue::TEvResponse::TPtr &ev, const TActor
488488
}
489489
FormHeadAndProceed();
490490

491-
if (GetContext().StartOffset && *GetContext().StartOffset != Partition()->StartOffset) {
492-
PQ_LOG_ERROR("StartOffset from meta and blobs are different: " << *GetContext().StartOffset << " != " << Partition()->StartOffset);
493-
return PoisonPill(ctx);
494-
}
495-
if (GetContext().EndOffset && *GetContext().EndOffset != Partition()->EndOffset) {
496-
PQ_LOG_ERROR("EndOffset from meta and blobs are different: " << *GetContext().EndOffset << " != " << Partition()->EndOffset);
497-
return PoisonPill(ctx);
498-
}
499-
500491
Done(ctx);
501492
break;
502493
case NKikimrProto::NODATA:

0 commit comments

Comments
 (0)