diff --git a/akka-cluster/src/main/scala/akka/cluster/Reachability.scala b/akka-cluster/src/main/scala/akka/cluster/Reachability.scala index 1f8eef1fb2..fd366abd86 100644 --- a/akka-cluster/src/main/scala/akka/cluster/Reachability.scala +++ b/akka-cluster/src/main/scala/akka/cluster/Reachability.scala @@ -195,7 +195,7 @@ private[cluster] class Reachability private ( } def remove(nodes: Iterable[UniqueAddress]): Reachability = { - val nodesSet = nodes.to(immutable.HashSet) + val nodesSet: Set[UniqueAddress] = nodes.toSet val newRecords = records.filterNot(r => nodesSet(r.observer) || nodesSet(r.subject)) val newVersions = versions -- nodes Reachability(newRecords, newVersions)