From 2dbff0dbd9e968bbc568db0cb1e75f437a0b98d6 Mon Sep 17 00:00:00 2001 From: changliiu Date: Fri, 5 Sep 2025 17:34:49 +0000 Subject: [PATCH] Make SpannerChangeStreamPlacementTableIT against Spanner prod. --- .../it/SpannerChangeStreamPlacementTableIT.java | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPlacementTableIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPlacementTableIT.java index 63c1f5c41035..13e103955689 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPlacementTableIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPlacementTableIT.java @@ -71,15 +71,7 @@ + "For now this test can only be exercised mannually.") public class SpannerChangeStreamPlacementTableIT { - // TODO change to spanner prod host once ready. - private static final String host = "https://staging-wrenchworks.sandbox.googleapis.com"; - - @ClassRule - public static final IntegrationTestEnv ENV = - new IntegrationTestEnv( - /*isPostgres=*/ false, - /*isPlacementTableBasedChangeStream=*/ true, - /*host=*/ Optional.of(host)); + @ClassRule public static final IntegrationTestEnv ENV = new IntegrationTestEnv(); @Rule public final transient TestPipeline pipeline = TestPipeline.create(); @@ -149,8 +141,7 @@ public void testReadSpannerChangeStreamImpl(TestPipeline testPipeline, String ro SpannerConfig.create() .withProjectId(projectId) .withInstanceId(instanceId) - .withDatabaseId(databaseId) - .withHost(StaticValueProvider.of(host)); + .withDatabaseId(databaseId); if (role != null) { spannerConfig = spannerConfig.withDatabaseRole(StaticValueProvider.of(role)); } @@ -210,8 +201,7 @@ public void testReadSpannerChangeStreamFilteredByTransactionTag() { SpannerConfig.create() .withProjectId(projectId) .withInstanceId(instanceId) - .withDatabaseId(databaseId) - .withHost(StaticValueProvider.of(host)); + .withDatabaseId(databaseId); // Filter records to only those from transactions with tag "app=beam;action=update" final PCollection tokens =