update the code style

vesoft-inc · Dec 27, 2023 · 761100b · 761100b
1 parent bd67f0b
commit 761100b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 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
@@ -5,20 +5,17 @@
 
 package org.apache.flink.connector.nebula.connection;
 
-
 import com.vesoft.nebula.client.graph.NebulaPoolConfig;
 import com.vesoft.nebula.client.graph.data.CASignedSSLParam;
 import com.vesoft.nebula.client.graph.data.HostAddress;
 import com.vesoft.nebula.client.graph.data.SSLParam;
 import com.vesoft.nebula.client.graph.data.SelfSignedSSLParam;
 import com.vesoft.nebula.client.graph.net.NebulaPool;
-
 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;
 import org.slf4j.LoggerFactory;
@@ -45,7 +42,6 @@ public NebulaPool getNebulaPool() throws UnknownHostException {
         }
 
         Collections.shuffle(addresses);
-        NebulaPool nebulaPool = new NebulaPool();
         NebulaPoolConfig poolConfig = new NebulaPoolConfig();
         poolConfig.setTimeout(nebulaClientOptions.getTimeout());
         poolConfig.setVersion(nebulaClientOptions.getVersion());
@@ -70,6 +66,7 @@ public NebulaPool getNebulaPool() throws UnknownHostException {
                     throw new IllegalArgumentException("ssl sign type is not supported.");
             }
         }
+        NebulaPool nebulaPool = new NebulaPool();
         if (nebulaPool.init(addresses, poolConfig)) {
             return nebulaPool;
         } else {

diff --git a/.../java/org/apache/flink/connector/nebula/connection/NebulaGraphConnectionProviderTest.java b/.../java/org/apache/flink/connector/nebula/connection/NebulaGraphConnectionProviderTest.java
@@ -10,9 +10,7 @@
 import com.vesoft.nebula.client.graph.exception.IOErrorException;
 import com.vesoft.nebula.client.graph.exception.NotValidConnectionException;
 import com.vesoft.nebula.client.graph.net.NebulaPool;
-
 import java.net.UnknownHostException;
-
 import org.apache.flink.connector.nebula.utils.SSLSignType;
 import org.junit.After;
 import org.junit.Before;
@@ -74,7 +72,8 @@ public void getNebulaPoolWithWrongVersion() {
             nebulaPool.getSession("root", "nebula", true);
         } catch (Exception e) {
             LOG.info("get session failed", e);
-            if (e.getMessage().contains("Current client is not compatible with the remote server")) {
+            if (e.getMessage()
+                    .contains("Current client is not compatible with the remote server")) {
                 assert true;
             } else {
                 assert false;