[beam] branch master updated: update query

[ki...@apache.org]

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

kileysok pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new c9f9f19321d update query
     new 3a6ef1d4cf6 Merge pull request #17234 from libingye816/fix-SpannerReadIT
c9f9f19321d is described below

commit c9f9f19321d710406adf2844a29ae1d6c2cc3048
Author: Michael Li <bi...@google.com>
AuthorDate: Thu Mar 31 20:34:01 2022 +0000

    update query
---
 .../test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java
index 09f118c9b72..7740bc44558 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java
@@ -267,10 +267,8 @@ public class SpannerReadIT {
                     .withSpannerConfig(pgSpannerConfig)
                     .withBatching(false)
                     .withQuery(
-                        String.format(
-                            "SELECT t.table_name FROM information_schema.tables AS t WHERE t"
-                                + ".table_catalog = '%s' AND t.table_schema = 'public'",
-                            pgSpannerConfig.getDatabaseId())))
+                        "SELECT t.table_name FROM information_schema.tables AS t WHERE t"
+                            + ".table_schema = 'public'"))
             .apply(
                 "Build PG query",
                 MapElements.into(TypeDescriptor.of(ReadOperation.class))