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);