shuffle graphd server (#94)

vesoft-inc · Apr 18, 2023 · ffc5d4c · ffc5d4c
1 parent 9bafb76
commit ffc5d4c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/nebula/GraphProvider.scala b/nebula-spark-common/src/main/scala/com/vesoft/nebula/connector/nebula/GraphProvider.scala
@@ -60,7 +60,8 @@ class GraphProvider(addresses: List[Address],
       case _ => throw new IllegalArgumentException("ssl sign type is not supported")
     }
   }
-  pool.init(address.asJava, nebulaPoolConfig)
+  val randAddr = scala.util.Random.shuffle(address)
+  pool.init(randAddr.asJava, nebulaPoolConfig)
 
   var session: Session = _