Fix DebeziumIO JmsIO PreCommit (#32926)

* Fix DebeziumIO JmsIO PreCommit * Update sdks/go/test/integration/io/xlang/debezium/debezium_test.go --------- Co-authored-by: Jack McCluskey <[email protected]>
apache · Oct 24, 2024 · 5cd261a · 5cd261a
1 parent 5a6b10a
commit 5cd261a
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/sdks/go/test/integration/io/xlang/debezium/debezium_test.go b/sdks/go/test/integration/io/xlang/debezium/debezium_test.go
@@ -34,7 +34,7 @@ import (
 )
 
 const (
-	debeziumImage = "debezium/example-postgres:latest"
+	debeziumImage = "quay.io/debezium/example-postgres:latest"
 	debeziumPort  = "5432/tcp"
 	maxRetries    = 5
 )

diff --git a/.../debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java b/.../debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java
@@ -56,7 +56,7 @@ public class DebeziumIOPostgresSqlConnectorIT {
   @ClassRule
   public static final PostgreSQLContainer<?> POSTGRES_SQL_CONTAINER =
       new PostgreSQLContainer<>(
-              DockerImageName.parse("debezium/example-postgres:latest")
+              DockerImageName.parse("quay.io/debezium/example-postgres:latest")
                   .asCompatibleSubstituteFor("postgres"))
           .withPassword("dbz")
           .withUsername("debezium")

diff --git a/...o/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java b/...o/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java
@@ -46,7 +46,7 @@ public class DebeziumReadSchemaTransformTest {
   @ClassRule
   public static final PostgreSQLContainer<?> POSTGRES_SQL_CONTAINER =
       new PostgreSQLContainer<>(
-              DockerImageName.parse("debezium/example-postgres:latest")
+              DockerImageName.parse("quay.io/debezium/example-postgres:latest")
                   .asCompatibleSubstituteFor("postgres"))
           .withPassword("dbz")
           .withUsername("debezium")

diff --git a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java
@@ -215,7 +215,7 @@ public void testPublishingThenReadingAll() throws IOException, JMSException {
     int unackRecords = countRemain(QUEUE);
     assertTrue(
         String.format("Too many unacknowledged messages: %d", unackRecords),
-        unackRecords < OPTIONS.getNumberOfRecords() * 0.002);
+        unackRecords < OPTIONS.getNumberOfRecords() * 0.003);
 
     // acknowledged records
     int ackRecords = OPTIONS.getNumberOfRecords() - unackRecords;

diff --git a/sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py b/sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py
@@ -107,7 +107,7 @@ def start_db_container(self, retries):
     for i in range(retries):
       try:
         self.db = PostgresContainer(
-            'debezium/example-postgres:latest',
+            'quay.io/debezium/example-postgres:latest',
             user=self.username,
             password=self.password,
             dbname=self.database)