Skip to content

Commit

Permalink
Apply in build
Browse files Browse the repository at this point in the history
Signed-off-by: Craig Perkins <[email protected]>
  • Loading branch information
cwperks committed Dec 5, 2024
1 parent cacff09 commit 8c5506a
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -382,9 +382,7 @@ public Builder extectedNodeStartupCount(int expectedNodeStartupCount) {
}

public Builder nodeSettings(Map<String, Object> settings) {
HashMap<String, Object> settingsCopy = new HashMap<>(settings);
settingsCopy.put("monitor.fs.health.enabled", false);
settingsCopy.forEach((key, value) -> {
settings.forEach((key, value) -> {
if (value instanceof List) {
List<String> values = ((List<?>) value).stream().map(String::valueOf).collect(Collectors.toList());
nodeOverrideSettingsBuilder.putList(key, values);
Expand Down Expand Up @@ -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<Integer, Settings> nodeSpecificSettings = new HashMap<>();
for (Map.Entry<Integer, Settings.Builder> entry : nodeSpecificOverrideSettingsBuilder.entrySet()) {
entry.getValue().put("monitor.fs.health.enabled", true);
nodeSpecificSettings.put(entry.getKey(), entry.getValue().build());
}
return new LocalCluster(
Expand Down

0 comments on commit 8c5506a

Please sign in to comment.