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