diff options
| author | alexvru <alexvru@ydb.tech> | 2022-09-22 17:27:02 +0300 |
|---|---|---|
| committer | alexvru <alexvru@ydb.tech> | 2022-09-22 17:27:02 +0300 |
| commit | e456e6648f9cd36eab42378984bb6f21003627dc (patch) | |
| tree | d4583a455f75fb23bbd7f200f9bf5ddf6345c7eb | |
| parent | e8cdc1150f2c8f9972bcbd5468972ee8e1b6cc85 (diff) | |
| download | ydb-e456e6648f9cd36eab42378984bb6f21003627dc.tar.gz | |
Relax RACE -> ERROR conversion
| -rw-r--r-- | ydb/core/blobstorage/dsproxy/dsproxy.h | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/blobstorage/dsproxy/dsproxy.h b/ydb/core/blobstorage/dsproxy/dsproxy.h index 80095da114..c4bb0d7e39 100644 --- a/ydb/core/blobstorage/dsproxy/dsproxy.h +++ b/ydb/core/blobstorage/dsproxy/dsproxy.h @@ -240,7 +240,7 @@ public: const TActorId& nodeWardenId = MakeBlobStorageNodeWardenID(self.SelfId().NodeId()); if (vdiskId.GroupGeneration < Info->GroupGeneration) { // vdisk is older than our group RacingDomains |= {&Info->GetTopology(), vdiskId}; - if (Info->GetQuorumChecker().CheckFailModelForGroupDomains(RacingDomains)) { + if (RacingDomains.GetNumSetItems() <= 1) { record.SetStatus(NKikimrProto::ERROR); auto adjustStatus = [](auto *v) { for (int i = 0; i < v->size(); ++i) { |