Skip to content

Commit c47474c

Browse files
committed
Fixed a rare crash in the partition actor
1 parent 1f4c818 commit c47474c

File tree

1 file changed

+0
-18
lines changed

1 file changed

+0
-18
lines changed

ydb/core/persqueue/pqtablet/partition/partition_init.cpp

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -337,13 +337,6 @@ void TInitMetaStep::LoadMeta(const NKikimrClient::TResponse& kvResponse, const T
337337
Partition()->BlobEncoder.NewHead.Offset = Partition()->BlobEncoder.Head.Offset = Partition()->BlobEncoder.EndOffset;
338338
}
339339

340-
if (meta.HasStartOffset()) {
341-
GetContext().StartOffset = meta.GetStartOffset();
342-
}
343-
if (meta.HasEndOffset()) {
344-
GetContext().EndOffset = meta.GetEndOffset();
345-
}
346-
347340
Partition()->SubDomainOutOfSpace = meta.GetSubDomainOutOfSpace();
348341
Partition()->EndWriteTimestamp = TInstant::MilliSeconds(meta.GetEndWriteTimestamp());
349342
Partition()->PendingWriteTimestamp = Partition()->EndWriteTimestamp;
@@ -508,17 +501,6 @@ void TInitDataRangeStep::Handle(TEvKeyValue::TEvResponse::TPtr &ev, const TActor
508501
FillBlobsMetaData(ctx);
509502
FormHeadAndProceed();
510503

511-
if (GetContext().StartOffset && *GetContext().StartOffset != Partition()->GetStartOffset()) {
512-
PQ_LOG_ERROR("StartOffset from meta and blobs are different: " << *GetContext().StartOffset << " != " << Partition()->GetStartOffset());
513-
Y_ABORT("meta is broken");
514-
return PoisonPill(ctx);
515-
}
516-
if (GetContext().EndOffset && *GetContext().EndOffset != Partition()->GetEndOffset()) {
517-
PQ_LOG_ERROR("EndOffset from meta and blobs are different: " << *GetContext().EndOffset << " != " << Partition()->GetEndOffset());
518-
Y_ABORT("meta is broken");
519-
return PoisonPill(ctx);
520-
}
521-
522504
Done(ctx);
523505
break;
524506
case NKikimrProto::NODATA:

0 commit comments

Comments
 (0)