Skip to content

Commit

Permalink
add missed applyCluster state change
Browse files Browse the repository at this point in the history
Signed-off-by: Kaushal Kumar <[email protected]>
  • Loading branch information
kaushalmahi12 committed Oct 1, 2024
1 parent baa39c5 commit 3c6adae
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public class QueryGroupService extends AbstractLifecycleComponent
private final ThreadPool threadPool;
private final ClusterService clusterService;
private final WorkloadManagementSettings workloadManagementSettings;
private final Set<QueryGroup> activeQueryGroups;
private Set<QueryGroup> activeQueryGroups;
private final Set<QueryGroup> deletedQueryGroups;
private final NodeDuressTrackers nodeDuressTrackers;

Expand Down Expand Up @@ -175,7 +175,6 @@ public void applyClusterState(ClusterChangedEvent event) {
// New query group detected
QueryGroup newQueryGroup = currentQueryGroups.get(queryGroupName);
// Perform any necessary actions with the new query group
this.activeQueryGroups.add(newQueryGroup);
queryGroupStateMap.put(newQueryGroup.get_id(), new QueryGroupState());
}
}
Expand All @@ -190,6 +189,7 @@ public void applyClusterState(ClusterChangedEvent event) {
queryGroupStateMap.remove(deletedQueryGroup.get_id());
}
}
this.activeQueryGroups = new HashSet<>(currentMetadata.queryGroups().values());
}

/**
Expand Down

0 comments on commit 3c6adae

Please sign in to comment.