From 85eaaffcccd6d708e2d9fd0a416de9c882db411a Mon Sep 17 00:00:00 2001 From: Anqi Date: Thu, 28 Dec 2023 11:04:59 +0800 Subject: [PATCH 1/2] support to auth for reader (#94) --- connector/pom.xml | 4 ++-- .../nebula/connection/NebulaStorageConnectionProvider.java | 3 +++ example/pom.xml | 2 +- pom.xml | 2 +- 4 files changed, 7 insertions(+), 4 deletions(-) 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 From f32f04fd129ca7c87b394478033dff46b70e2e4b Mon Sep 17 00:00:00 2001 From: Anqi Date: Fri, 29 Dec 2023 09:59:55 +0800 Subject: [PATCH 2/2] update passphrase --- .github/workflows/release.yml | 2 +- .github/workflows/snapshot.yml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 }}