fix assertion error

vesoft-inc · Jul 22, 2022 · 6dbf56b · 6dbf56b
1 parent 3a7657b
commit 6dbf56b
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/...c/test/java/org/apache/flink/connector/nebula/source/AbstractNebulaInputFormatITTest.java b/...c/test/java/org/apache/flink/connector/nebula/source/AbstractNebulaInputFormatITTest.java
@@ -34,15 +34,15 @@ public class AbstractNebulaInputFormatITTest {
 
     private static final Logger LOGGER =
             LoggerFactory.getLogger(AbstractNebulaInputFormatITTest.class);
-    private static final String META_ADDRESS = "192.168.200.135:9559";
-    private static final String GRAPH_ADDRESS = "192.168.200.135:9669";
+    private static final String META_ADDRESS = "127.0.0.1:9559";
+    private static final String GRAPH_ADDRESS = "127.0.0.1:9669";
     private static final String USERNAME = "root";
     private static final String PASSWORD = "nebula";
 
     private static final String[] stats = new String[]{
-        "CREATE SPACE IF NOT EXISTS `flinkSink722` (partition_num = 100, charset = utf8,"
+        "CREATE SPACE IF NOT EXISTS `flinkSink` (partition_num = 100, charset = utf8,"
                     + " replica_factor = 3, collate = utf8_bin, vid_type = INT64);"
-                    + "USE `flinkSink722`;",
+                    + "USE `flinkSink`;",
         "CREATE TAG IF NOT EXISTS person (col1 string, col2 fixed_string(8), col3 int8,"
                     + " col4 int16, col5 int32,"
                     + " col6 int64, col7 date, col8 datetime, col9 timestamp, col10 bool,"
@@ -166,7 +166,7 @@ public void mockNebulaData() {
             boolean initResult = pool.init(addresses, nebulaPoolConfig);
             if (!initResult) {
                 LOGGER.error("pool init failed.");
-                assert false;
+                assert (false);
             }
             session = pool.getSession(USERNAME, PASSWORD, true);
             createSchema(session);
@@ -206,12 +206,12 @@ public void testVertexSource() throws ExecutionException, InterruptedException {
                 + " col14 STRING"
                 + ") WITH ("
                 + " 'connector' = 'nebula',"
-                + " 'meta-address' = '192.168.200.135:9559',"
-                + " 'graph-address' = '192.168.200.135:9669',"
+                + " 'meta-address' = '127.0.0.1:9559',"
+                + " 'graph-address' = '127.0.0.1:9669',"
                 + " 'username' = 'root',"
                 + " 'password' = 'nebula',"
                 + " 'data-type' = 'vertex',"
-                + " 'graph-space' = 'flinkSink722'"
+                + " 'graph-space' = 'flinkSink'"
                 + ")";
         tableEnv.executeSql(creatSourceDDL);
 
@@ -267,11 +267,11 @@ public void testEdgeSource() throws ExecutionException, InterruptedException {
                 + " col14 STRING"
                 + ") WITH ("
                 + " 'connector' = 'nebula',"
-                + " 'meta-address' = '192.168.200.135:9559',"
-                + " 'graph-address' = '192.168.200.135:9669',"
+                + " 'meta-address' = '127.0.0.1:9559',"
+                + " 'graph-address' = '127.0.0.1:9669',"
                 + " 'username' = 'root',"
                 + " 'password' = 'nebula',"
-                + " 'graph-space' = 'flinkSink722',"
+                + " 'graph-space' = 'flinkSink',"
                 + " 'data-type'='edge',"
                 + " 'src-id-index'='0',"
                 + " 'dst-id-index'='1',"