Skip to content

Commit 71e5757

Browse files
committed
Minor optimization to previous commit
1 parent 73f9141 commit 71e5757

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/java/com/datastax/oss/driver/internal/core/loadbalancing/BasicLoadBalancingPolicy.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -323,9 +323,8 @@ protected Queue<Node> maybeAddDcFailover(@Nullable Request request, @NonNull Que
323323

324324
@Override
325325
protected Object[] computeNodes() {
326-
Set<String> dcs = liveNodes.dcs();
327326
Object[] remoteNodes =
328-
dcs.stream()
327+
liveNodes.dcs().stream()
329328
.filter(Predicates.not(Predicates.equalTo(localDc)))
330329
.flatMap(dc -> liveNodes.dc(dc).stream().limit(maxNodesPerRemoteDc))
331330
.toArray();

0 commit comments

Comments
 (0)