This is an automated email from the ASF dual-hosted git repository. yhu pushed a commit to branch revert-25152-reenablePostgres in repository https://gitbox.apache.org/repos/asf/beam.git
commit 673b2d7d46ad51e4db3594a99ee289c59e84f0b2 Author: Yi Hu <[email protected]> AuthorDate: Tue Jan 31 12:27:20 2023 -0500 Revert "[BEAM-12164] Enable postgres IT for change streams (#25152)" This reverts commit a96afe2c57c45a869a622086eaa4f81305f06e72. --- .../io/gcp/spanner/changestreams/it/SpannerChangeStreamPostgresIT.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPostgresIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPostgresIT.java index f5e37325bb3..82e7c72079e 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPostgresIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamPostgresIT.java @@ -49,6 +49,7 @@ import org.joda.time.Instant; import org.junit.Before; import org.junit.BeforeClass; import org.junit.ClassRule; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.runner.RunWith; @@ -90,6 +91,7 @@ public class SpannerChangeStreamPostgresIT { pipeline.getOptions().as(ChangeStreamTestPipelineOptions.class).setBlockOnRun(false); } + @Ignore("BEAM-14277 Until Postgres is supported") @Test public void testReadSpannerChangeStream() { // Defines how many rows are going to be inserted / updated / deleted in the test
