Skip to content

Commit 6fb984c

Browse files
New Data Tiers role support (#1613) (#1616)
Should adress #1612 Co-authored-by: Luca Belluccini <[email protected]>
1 parent 85bf34d commit 6fb984c

File tree

1 file changed

+3
-3
lines changed
  • mr/src/main/java/org/elasticsearch/hadoop/serialization/dto

1 file changed

+3
-3
lines changed

mr/src/main/java/org/elasticsearch/hadoop/serialization/dto/NodeInfo.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,8 @@ public NodeInfo(String id, Map<String, Object> map) {
5858
this.isIngest = false;
5959
} else {
6060
List<String> roles = (List<String>) map.get("roles");
61-
this.isClient = roles.contains("data") == false;
62-
this.isData = roles.contains("data");
61+
this.isData = roles.stream().anyMatch(role -> role.contains("data"));
62+
this.isClient = !this.isData;
6363
this.isIngest = roles.contains("ingest");
6464
}
6565
Map<String, Object> httpMap = (Map<String, Object>) map.get("http");
@@ -152,4 +152,4 @@ public String toString() {
152152
", isData=" + isData +
153153
'}';
154154
}
155-
}
155+
}

0 commit comments

Comments
 (0)