From ec930392b1fe51195af17f26dc2807d1d7caa92b Mon Sep 17 00:00:00 2001
From: Anqi <anqi.wang@vesoft.com>
Date: Sun, 7 Apr 2024 18:00:13 +0800
Subject: [PATCH] support auth for flink source

---
 .../nebula/connection/NebulaStorageConnectionProvider.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaStorageConnectionProvider.java b/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaStorageConnectionProvider.java
index 3273693..6ef19c0 100644
--- a/connector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaStorageConnectionProvider.java
+++ b/connector/src/main/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.");
         }