diff options
| author | Alexander Rutkovsky <[email protected]> | 2025-01-10 19:56:40 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-01-10 16:56:40 +0000 |
| commit | 6551911f361e05eae28f40e82dcd316ad9d0e1d6 (patch) | |
| tree | b67aa1b5962cc5b626dc6693dc2119f085ed4398 | |
| parent | 77c19537e738a5a525ad6ff17aab6999ee82d7c2 (diff) | |
Fix group resolver bug (#13282)
| -rw-r--r-- | ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp b/ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp index 8eff8ea0836..950241c7644 100644 --- a/ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp +++ b/ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp @@ -336,9 +336,12 @@ namespace NKikimr::NStorage { if (const auto it = Groups.find(r.GetGroupId()); it != Groups.end() && it->second.Group) { record.MutableGroup()->CopyFrom(*it->second.Group); } + THashSet<TGroupId> groupsAdded; for (const auto& [key, value] : LocalVDisks) { if (const auto& r = value.RuntimeData; r && !r->DonorMode) { - record.AddStartedGroupIds(r->GroupInfo->GroupID.GetRawId()); + if (const auto& groupId = r->GroupInfo->GroupID; groupsAdded.insert(groupId).second) { + record.AddStartedGroupIds(groupId.GetRawId()); + } } } Send(ev->Sender, res.release(), 0, ev->Cookie); |
