Skip to content

Commit

Permalink
shards assignment to local Node when fanout flag is disabled
Browse files Browse the repository at this point in the history
Signed-off-by: Riya Saxena <[email protected]>
  • Loading branch information
riysaxen-amzn committed Dec 17, 2024
1 parent 8f37a77 commit 96e415b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -243,7 +243,7 @@ class DocumentLevelMonitorRunner : MonitorRunner() {
* if fanout flag is disabled and force assign all shards to local node
* thus effectively making the fan-out a single node operation.
* This is done to avoid de-dupe Alerts generated by Aggregation Sigma Rules
**/
**/
val localNode = monitorCtx.clusterService!!.localNode()
val nodeMap: Map<String, DiscoveryNode> = if (monitor.fanoutEnabled == true) {
getNodes(monitorCtx)
Expand Down

0 comments on commit 96e415b

Please sign in to comment.