fix example problem (#71)

vesoft-inc · Jul 23, 2022 · 34ecb07 · 34ecb07
1 parent 428de90
commit 34ecb07
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/example/src/main/java/org/apache/flink/FlinkConnectorExample.java b/example/src/main/java/org/apache/flink/FlinkConnectorExample.java
@@ -28,7 +28,7 @@
  * make sure your nebula graph has create Space, space schema:
  *
  * <p>"CREATE SPACE `flinkSink` (partition_num = 100, replica_factor = 3, charset = utf8,
- * collate = utf8_bin, vid_type = INT64, atomic_edge = false) ON default"
+ * collate = utf8_bin, vid_type = INT64, atomic_edge = false)"
  *
  * <p>"USE `flinkSink`"
  *

diff --git a/example/src/main/java/org/apache/flink/FlinkConnectorSourceExample.java b/example/src/main/java/org/apache/flink/FlinkConnectorSourceExample.java
@@ -31,7 +31,7 @@
  * Space schema:
  *
  * <p>"CREATE SPACE `flinkSource` (partition_num = 100, replica_factor = 3, charset = utf8,
- * collate = utf8_bin, vid_type = INT64, atomic_edge = false) ON default"
+ * collate = utf8_bin, vid_type = INT64, atomic_edge = false)"
  *
  * <p>"USE `flinkSource`"
  *
@@ -79,6 +79,7 @@ public static void initConfig() {
 
         NebulaClientOptions nebulaClientOptionsWithCaSSL =
                 new NebulaClientOptions.NebulaClientOptionsBuilder()
+                        .setMetaAddress("127.0.0.1:9559")
                         .setEnableMetaSSL(true)
                         .setEnableStorageSSL(true)
                         .setSSLSignType(SSLSighType.CA)
@@ -91,10 +92,11 @@ public static void initConfig() {
 
         NebulaClientOptions nebulaClientOptionsWithSelfSSL =
                 new NebulaClientOptions.NebulaClientOptionsBuilder()
+                        .setMetaAddress("127.0.0.1:9559")
                         .setEnableMetaSSL(true)
                         .setEnableStorageSSL(true)
                         .setSSLSignType(SSLSighType.SELF)
-                        .setCaSignParam("example/src/main/resources/ssl/selfsigned.pem",
+                        .setSelfSignParam("example/src/main/resources/ssl/selfsigned.pem",
                                 "example/src/main/resources/ssl/selfsigned.key",
                                 "vesoft")
                         .build();