summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexander Rutkovsky <[email protected]>2025-01-10 19:56:40 +0300
committerGitHub <[email protected]>2025-01-10 16:56:40 +0000
commit6551911f361e05eae28f40e82dcd316ad9d0e1d6 (patch)
treeb67aa1b5962cc5b626dc6693dc2119f085ed4398
parent77c19537e738a5a525ad6ff17aab6999ee82d7c2 (diff)
Fix group resolver bug (#13282)
-rw-r--r--ydb/core/blobstorage/nodewarden/node_warden_group_resolver.cpp5
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);