From 82530074a4f42d558efdb17552d079d51b67a469 Mon Sep 17 00:00:00 2001 From: Anqi Date: Tue, 18 Apr 2023 14:23:07 +0800 Subject: [PATCH] shuffle graphd server --- .../com/vesoft/nebula/connector/nebula/GraphProvider.scala | 3 ++- 1 file changed, 2 insertions(+), 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 index a9b7a3ab..8343da91 100644 --- 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 = _