diff --git a/.github/workflows/beam_PreCommit_Java_GCP_IO_Direct.yml b/.github/workflows/beam_PreCommit_Java_GCP_IO_Direct.yml index e3fa7afa2bdb..c97fa20f18d6 100644 --- a/.github/workflows/beam_PreCommit_Java_GCP_IO_Direct.yml +++ b/.github/workflows/beam_PreCommit_Java_GCP_IO_Direct.yml @@ -153,4 +153,4 @@ jobs: uses: codecov/codecov-action@v3 with: file: ${{ steps.jacoco_report_path.outputs.path }} - flags: java \ No newline at end of file + flags: java diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java index bbce5fad82f4..4e2665e21b55 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java @@ -2109,6 +2109,8 @@ private static Dialect getDialect(SpannerConfig spannerConfig, PipelineOptions p // Allow passing the credential from pipeline options to the getDialect() call. SpannerConfig spannerConfigWithCredential = buildSpannerConfigWithCredential(spannerConfig, pipelineOptions); + + try (SpannerAccessor sa = SpannerAccessor.getOrCreate(spannerConfigWithCredential)) { DatabaseClient databaseClient = sa.getDatabaseClient(); return databaseClient.getDialect();