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.
2 parents 8b269a1 + 0f45726 commit 12b19d9Copy full SHA for 12b19d9
ydb/core/blobstorage/dsproxy/dsproxy_put.cpp
@@ -205,6 +205,11 @@ class TBlobStorageGroupPutRequest : public TBlobStorageGroupRequestActor<TBlobSt
205
206
if (record.HasIncarnationGuid()) {
207
HandleIncarnation(issue, orderNumber, record.GetIncarnationGuid());
208
+ } else if (record.GetStatus() != NKikimrProto::OK) { // we can't obtain status from the vdisk; assume it has not been written
209
+ Y_ABORT_UNLESS(orderNumber < IncarnationRecords.size());
210
+ IncarnationRecords[orderNumber] = {};
211
+ PutImpl.InvalidatePartStates(orderNumber);
212
+ ++*Mon->NodeMon->IncarnationChanges;
213
}
214
215
Action();
0 commit comments