add shuffle for hosts

vesoft-inc · Nov 1, 2021 · 722aae5 · 722aae5
1 parent a3d1634
commit 722aae5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...main/java/org.apache.flink/connector/nebula/connection/NebulaGraphConnectionProvider.java b/...main/java/org.apache.flink/connector/nebula/connection/NebulaGraphConnectionProvider.java
@@ -18,6 +18,7 @@
 import java.io.Serializable;
 import java.net.UnknownHostException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import org.apache.flink.connector.nebula.utils.NebulaConstant;
 import org.slf4j.Logger;
@@ -44,6 +45,7 @@ public NebulaPool getNebulaPool() throws UnknownHostException {
             addresses.add(new HostAddress(hostAndPort[0], Integer.parseInt(hostAndPort[1])));
         }
 
+        Collections.shuffle(addresses);
         NebulaPool nebulaPool = new NebulaPool();
         NebulaPoolConfig poolConfig = new NebulaPoolConfig();
         poolConfig.setTimeout(nebulaClientOptions.getTimeout());