Skip to content

Commit 1cfe0b3

Browse files
WIP
1 parent e491de2 commit 1cfe0b3

File tree

1 file changed

+1
-2
lines changed
  • modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp

1 file changed

+1
-2
lines changed

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6837,8 +6837,7 @@ else if (log.isDebugEnabled())
68376837

68386838
if (req.client()) {
68396839
if (req.dcId() != null && !Objects.equals(req.dcId(), locNode.dataCenterId())) {
6840-
List<TcpDiscoveryNode> dcNodes = ring.serverNodes().stream()
6841-
.filter(TcpDiscoveryNode::visible)
6840+
List<TcpDiscoveryNode> dcNodes = ring.visibleNodes().stream()
68426841
.filter(node -> node.dataCenterId() != null && node.dataCenterId().equals(req.dcId()))
68436842
.collect(
68446843
collectingAndThen(

0 commit comments

Comments
 (0)