support auth for flink source (#99)

vesoft-inc · Apr 7, 2024 · 4afb041 · 4afb041
1 parent e027afd
commit 4afb041
Showing 1 changed file with 2 additions and 0 deletions.
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,8 @@ public StorageClient getStorageClient() throws Exception {
             storageClient = new StorageClient(addresses, timeout);
         }
 
+        storageClient.setUser(nebulaClientOptions.getUsername());
+        storageClient.setPassword(nebulaClientOptions.getPassword());
         if (!storageClient.connect()) {
             throw new Exception("failed to connect storaged.");
         }