Don't use Guava as compile dependency

This commit is contained in:
Yannick Welsch 2017-01-10 16:26:26 +01:00
parent 78bb56671e
commit 8be28aa58a
1 changed files with 3 additions and 2 deletions

View File

@ -18,7 +18,6 @@
*/ */
package org.elasticsearch.cluster.service; package org.elasticsearch.cluster.service;
import com.google.common.collect.Iterables;
import org.apache.logging.log4j.Level; import org.apache.logging.log4j.Level;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage; import org.apache.logging.log4j.message.ParameterizedMessage;
@ -1068,7 +1067,9 @@ public class ClusterServiceTests extends ESTestCase {
@Override @Override
public void disconnectFromNodesExcept(Iterable<DiscoveryNode> nodesToKeep) { public void disconnectFromNodesExcept(Iterable<DiscoveryNode> nodesToKeep) {
currentNodes.removeIf(node -> Iterables.contains(nodesToKeep, node) == false); Set<DiscoveryNode> nodeSet = new HashSet<>();
nodesToKeep.iterator().forEachRemaining(nodeSet::add);
currentNodes.removeIf(node -> nodeSet.contains(node) == false);
} }
}); });
AtomicBoolean failToCommit = new AtomicBoolean(); AtomicBoolean failToCommit = new AtomicBoolean();