From c726525a9e8d43ae5a47f477fb6616de93c1cd3b Mon Sep 17 00:00:00 2001 From: Robert Burke Date: Mon, 5 Feb 2024 17:49:16 -0800 Subject: [PATCH] Fix JdbcIO PreCommit mysql breaking change (#30221) Co-authored-by: Yi Hu --- .../apache/beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java b/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java index 0042d93aedfc..dc94b65cf25a 100644 --- a/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java +++ b/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java @@ -125,7 +125,10 @@ public void evaluate() throws Throwable { } }; - @ClassRule public static JdbcDatabaseContainer mysql = new MySQLContainer<>("mysql"); + // TODO(yathu) unpin tag when the fix of + // https://github.com/testcontainers/testcontainers-java/issues/8130 + // released and upgraded in Beam + @ClassRule public static JdbcDatabaseContainer mysql = new MySQLContainer<>("mysql:8.2"); @ClassRule public static JdbcDatabaseContainer postgres = new PostgreSQLContainer<>("postgres");