You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jo...@apache.org on 2023/01/24 15:09:56 UTC

[beam] branch release-2.45.0 updated: Remove databaseRole from metadata DB requests in SpannerIO.ReadChangeStream (#25108)

This is an automated email from the ASF dual-hosted git repository.

johncasey pushed a commit to branch release-2.45.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.45.0 by this push:
     new 1734d537fdc Remove databaseRole from metadata DB requests in SpannerIO.ReadChangeStream (#25108)
1734d537fdc is described below

commit 1734d537fdc003d51c9ef84f8fd31cba6ee016b6
Author: Doug Judd <nu...@google.com>
AuthorDate: Tue Jan 24 07:09:47 2023 -0800

    Remove databaseRole from metadata DB requests in SpannerIO.ReadChangeStream (#25108)
---
 .../src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java      | 1 +
 1 file changed, 1 insertion(+)

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 913d98ff8d1..b4a451378ce 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
@@ -1629,6 +1629,7 @@ public class SpannerIO {
               .toBuilder()
               .setInstanceId(StaticValueProvider.of(partitionMetadataInstanceId))
               .setDatabaseId(StaticValueProvider.of(partitionMetadataDatabaseId))
+              .setDatabaseRole(null)
               .build();
       Dialect changeStreamDatabaseDialect = getDialect(changeStreamSpannerConfig);
       Dialect metadataDatabaseDialect = getDialect(partitionMetadataSpannerConfig);