diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
index f8e937b..181a128 100644
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -42,6 +42,6 @@ jobs:
uses: samuelmeuli/action-maven-publish@v1
with:
gpg_private_key: ${{ secrets.JAVA_GPG_PRIVATE_KEY }}
- gpg_passphrase: ${{ secrets.JAVA_GPG_PASSPHRASE }}
+ gpg_passphrase: ""
nexus_username: ${{ secrets.OSSRH_USERNAME }}
nexus_password: ${{ secrets.OSSRH_TOKEN }}
diff --git a/.github/workflows/snapshot.yml b/.github/workflows/snapshot.yml
index d9ccea2..2491651 100644
--- a/.github/workflows/snapshot.yml
+++ b/.github/workflows/snapshot.yml
@@ -44,6 +44,6 @@ jobs:
uses: samuelmeuli/action-maven-publish@v1
with:
gpg_private_key: ${{ secrets.JAVA_GPG_PRIVATE_KEY }}
- gpg_passphrase: ${{ secrets.JAVA_GPG_PASSPHRASE }}
+ gpg_passphrase: ""
nexus_username: ${{ secrets.OSSRH_USERNAME }}
nexus_password: ${{ secrets.OSSRH_TOKEN }}
diff --git a/connector/pom.xml b/connector/pom.xml
index beed8da..1728fee 100644
--- a/connector/pom.xml
+++ b/connector/pom.xml
@@ -5,7 +5,7 @@
nebula-flink
com.vesoft
- 3.0-SNAPSHOT
+ 3.7.0-zszq
../pom.xml
4.0.0
@@ -13,7 +13,7 @@
nebula-flink-connector
- 3.0-SNAPSHOT
+ 3.7.0-zszq
1.14.4
2.11
1.8
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 aa82568..e0db79a 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,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
index 00a2ac5..eadfd5d 100644
--- a/example/pom.xml
+++ b/example/pom.xml
@@ -5,7 +5,7 @@
nebula-flink
com.vesoft
- 3.0-SNAPSHOT
+ 3.7.0-zszq
../pom.xml
4.0.0
diff --git a/pom.xml b/pom.xml
index d06a60d..55526fa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -7,7 +7,7 @@
com.vesoft
nebula-flink
pom
- 3.0-SNAPSHOT
+ 3.7.0-zszq
connector