support to auth for reader (#94)

vesoft-inc · Dec 28, 2023 · 85eaaff · 85eaaff
1 parent b6de2c4
commit 85eaaff
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 4 deletions.
diff --git a/connector/pom.xml b/connector/pom.xml
@@ -5,15 +5,15 @@
     <parent>
         <artifactId>nebula-flink</artifactId>
         <groupId>com.vesoft</groupId>
-        <version>3.0-SNAPSHOT</version>
+        <version>3.7.0-zszq</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>nebula-flink-connector</artifactId>
 
     <properties>
-        <nebula.version>3.0-SNAPSHOT</nebula.version>
+        <nebula.version>3.7.0-zszq</nebula.version>
         <flink.version>1.14.4</flink.version>
         <scala.binary.version>2.11</scala.binary.version>
         <compiler.source.version>1.8</compiler.source.version>

diff --git a/...in/java/org.apache.flink/connector/nebula/connection/NebulaStorageConnectionProvider.java b/...in/java/org.apache.flink/connector/nebula/connection/NebulaStorageConnectionProvider.java
@@ -56,6 +56,9 @@ public StorageClient getStorageClient() throws Exception {
             storageClient = new StorageClient(addresses, timeout);
         }
 
+        storageClient.setGraphAddress(nebulaClientOptions.getGraphAddress());
+        storageClient.setUser(nebulaClientOptions.getUsername());
+        storageClient.setPassword(nebulaClientOptions.getPassword());
         storageClient.setVersion(nebulaClientOptions.getVersion());
         if (!storageClient.connect()) {
             throw new Exception("failed to connect storaged.");

diff --git a/example/pom.xml b/example/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>nebula-flink</artifactId>
         <groupId>com.vesoft</groupId>
-        <version>3.0-SNAPSHOT</version>
+        <version>3.7.0-zszq</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

diff --git a/pom.xml b/pom.xml
@@ -7,7 +7,7 @@
     <groupId>com.vesoft</groupId>
     <artifactId>nebula-flink</artifactId>
     <packaging>pom</packaging>
-    <version>3.0-SNAPSHOT</version>
+    <version>3.7.0-zszq</version>
 
     <modules>
         <module>connector</module>