Skip to content

Commit ef560cd

Browse files
committed
YARN-10823. Fix default node label if no label is defined
1 parent f509d98 commit ef560cd

File tree

1 file changed

+7
-1
lines changed
  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity

1 file changed

+7
-1
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ConfiguredNodeLabels.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,13 @@ public void setLabelsByQueue(
8181
* @return all node labels
8282
*/
8383
public Set<String> getAllConfiguredLabels() {
84-
return configuredNodeLabelsByQueue.values().stream()
84+
Set<String> nodeLabels = configuredNodeLabelsByQueue.values().stream()
8585
.flatMap(Set::stream).collect(Collectors.toSet());
86+
87+
if (nodeLabels.size() == 0) {
88+
nodeLabels = NO_LABEL;
89+
}
90+
91+
return nodeLabels;
8692
}
8793
}

0 commit comments

Comments
 (0)