diff --git a/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalCluster.java b/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalCluster.java index 30332c8603..5ca6b86672 100644 --- a/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalCluster.java +++ b/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalCluster.java @@ -382,9 +382,7 @@ public Builder extectedNodeStartupCount(int expectedNodeStartupCount) { } public Builder nodeSettings(Map settings) { - HashMap settingsCopy = new HashMap<>(settings); - settingsCopy.put("monitor.fs.health.enabled", false); - settingsCopy.forEach((key, value) -> { + settings.forEach((key, value) -> { if (value instanceof List) { List values = ((List) value).stream().map(String::valueOf).collect(Collectors.toList()); nodeOverrideSettingsBuilder.putList(key, values); @@ -556,9 +554,11 @@ public LocalCluster build() { testCertificates = new TestCertificates(clusterManager.getNodes()); } clusterName += "_" + num.incrementAndGet(); + nodeOverrideSettingsBuilder.put("monitor.fs.health.enabled", true); Settings settings = nodeOverrideSettingsBuilder.build(); Map nodeSpecificSettings = new HashMap<>(); for (Map.Entry entry : nodeSpecificOverrideSettingsBuilder.entrySet()) { + entry.getValue().put("monitor.fs.health.enabled", true); nodeSpecificSettings.put(entry.getKey(), entry.getValue().build()); } return new LocalCluster(