From 546bc29d08427323a441175645787ea3b830841d Mon Sep 17 00:00:00 2001
From: Doug Judd <nuggetwheat@google.com>
Date: Tue, 15 Nov 2022 17:47:35 +0000
Subject: [PATCH] Strip FGAC database role from changestreams metadata requests

---
 .../beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java
index 7c94720c7875..43b581480dc4 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java
@@ -72,7 +72,7 @@ public DaoFactory(
     }
     this.changeStreamSpannerConfig = changeStreamSpannerConfig;
     this.changeStreamName = changeStreamName;
-    this.metadataSpannerConfig = metadataSpannerConfig;
+    this.metadataSpannerConfig = metadataSpannerConfig.withDatabaseRole(null);
     this.partitionMetadataTableName = partitionMetadataTableName;
     this.rpcPriority = rpcPriority;
     this.jobName = jobName;