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 <[email protected]>
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);

Reply via email to