We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f600bdf commit 0c2eebeCopy full SHA for 0c2eebe
ydb/services/persqueue_v1/actors/partition_actor.cpp
@@ -1210,7 +1210,6 @@ bool TPartitionActor::SendNextRestorePublishRequest() {
1210
void TPartitionActor::OnDirectReadsRestored() {
1211
Y_ABORT_UNLESS(DirectReadsToRestore.empty() && DirectReadsToPublish.empty() && DirectReadsToForget.empty());
1212
DirectReadRestoreStage = EDirectReadRestoreStage::None;
1213
- Y_ABORT_UNLESS(!DirectReadId || RestoredDirectReadId < DirectReadId);
1214
1215
const auto& ctx = ActorContext();
1216
LOG_DEBUG_S(ctx, NKikimrServices::PQ_READ_PROXY, PQ_LOG_PREFIX << " " << Partition
0 commit comments