Remove streaming from isReplacementSource

dakrone · dakrone · commit 238112a36c50 · 2021-10-04T13:26:27.000-06:00
diff --git a/server/src/main/java/org/elasticsearch/cluster/routing/allocation/decider/NodeReplacementAllocationDecider.java b/server/src/main/java/org/elasticsearch/cluster/routing/allocation/decider/NodeReplacementAllocationDecider.java
@@ -137,9 +137,8 @@ private static boolean isReplacementSource(Metadata metadata, String nodeId) {
         if (nodeId == null || replacementOngoing(metadata) == false) {
             return false;
         }
-        return metadata.nodeShutdowns().values().stream()
-            .filter(shutdown -> shutdown.getType().equals(SingleNodeShutdownMetadata.Type.REPLACE))
-            .anyMatch(shutdown -> shutdown.getNodeId().equals(nodeId));
+        return metadata.nodeShutdowns().containsKey(nodeId) &&
+            metadata.nodeShutdowns().get(nodeId).getType().equals(SingleNodeShutdownMetadata.Type.REPLACE);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -137,9 +137,8 @@ private static boolean isReplacementSource(Metadata metadata, String nodeId) {`
`137`	`137`	`if (nodeId == null \|\| replacementOngoing(metadata) == false) {`
`138`	`138`	`return false;`
`139`	`139`	`}`
`140`		`- return metadata.nodeShutdowns().values().stream()`
`141`		`- .filter(shutdown -> shutdown.getType().equals(SingleNodeShutdownMetadata.Type.REPLACE))`
`142`		`- .anyMatch(shutdown -> shutdown.getNodeId().equals(nodeId));`
	`140`	`+ return metadata.nodeShutdowns().containsKey(nodeId) &&`
	`141`	`+ metadata.nodeShutdowns().get(nodeId).getType().equals(SingleNodeShutdownMetadata.Type.REPLACE);`
`143`	`142`	`}`
`144`	`143`
`145`	`144`	`/**`