support auth for flink source (#99)

Nicole00 · web-flow · commit 4afb04176dd4 · 2024-04-07T18:32:27.000+08:00
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
@@ -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.");
         }

Original file line number	Diff line number	Diff line change
`@@ -56,6 +56,8 @@ public StorageClient getStorageClient() throws Exception {`
`56`	`56`	`storageClient = new StorageClient(addresses, timeout);`
`57`	`57`	`}`
`58`	`58`
	`59`	`+ storageClient.setUser(nebulaClientOptions.getUsername());`
	`60`	`+ storageClient.setPassword(nebulaClientOptions.getPassword());`
`59`	`61`	`if (!storageClient.connect()) {`
`60`	`62`	`throw new Exception("failed to connect storaged.");`
`61`	`63`	`}`