[test] Fix TiDBE2eITCase by updating the container version to avoid `…

…tikv disk full` failure (apache#2402)
zhongqishang · Aug 18, 2023 · 8098c82 · 8098c82
1 parent 90ed963
commit 8098c82
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/TiDBE2eITCase.java b/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/TiDBE2eITCase.java
@@ -71,7 +71,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
 
     @ClassRule
     public static final GenericContainer<?> PD =
-            new GenericContainer<>("pingcap/pd:v6.0.0")
+            new GenericContainer<>("pingcap/pd:v6.1.0")
                     .withExposedPorts(PD_PORT)
                     .withFileSystemBind("src/test/resources/docker/tidb/pd.toml", "/pd.toml")
                     .withCommand(
@@ -92,7 +92,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
 
     @ClassRule
     public static final GenericContainer<?> TIKV =
-            new GenericContainer<>("pingcap/tikv:v6.0.0")
+            new GenericContainer<>("pingcap/tikv:v6.1.0")
                     .withExposedPorts(TIKV_PORT)
                     .withFileSystemBind("src/test/resources/docker/tidb/tikv.toml", "/tikv.toml")
                     .withCommand(
@@ -110,7 +110,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
 
     @ClassRule
     public static final GenericContainer<?> TIDB =
-            new GenericContainer<>("pingcap/tidb:v6.0.0")
+            new GenericContainer<>("pingcap/tidb:v6.1.0")
                     .withExposedPorts(TIDB_PORT)
                     .withFileSystemBind("src/test/resources/docker/tidb/tidb.toml", "/tidb.toml")
                     .withCommand(

diff --git a/flink-connector-tidb-cdc/src/test/java/com/ververica/cdc/connectors/tidb/TiDBTestBase.java b/flink-connector-tidb-cdc/src/test/java/com/ververica/cdc/connectors/tidb/TiDBTestBase.java
@@ -72,7 +72,7 @@ public class TiDBTestBase extends AbstractTestBase {
 
     @ClassRule
     public static final GenericContainer<?> PD =
-            new FixedHostPortGenericContainer<>("pingcap/pd:v6.0.0")
+            new FixedHostPortGenericContainer<>("pingcap/pd:v6.1.0")
                     .withFileSystemBind("src/test/resources/config/pd.toml", "/pd.toml")
                     .withFixedExposedPort(pdPort, PD_PORT_ORIGIN)
                     .withCommand(
@@ -92,7 +92,7 @@ public class TiDBTestBase extends AbstractTestBase {
 
     @ClassRule
     public static final GenericContainer<?> TIKV =
-            new FixedHostPortGenericContainer<>("pingcap/tikv:v6.0.0")
+            new FixedHostPortGenericContainer<>("pingcap/tikv:v6.1.0")
                     .withFixedExposedPort(TIKV_PORT_ORIGIN, TIKV_PORT_ORIGIN)
                     .withFileSystemBind("src/test/resources/config/tikv.toml", "/tikv.toml")
                     .withCommand(
@@ -110,7 +110,7 @@ public class TiDBTestBase extends AbstractTestBase {
 
     @ClassRule
     public static final GenericContainer<?> TIDB =
-            new GenericContainer<>("pingcap/tidb:v6.0.0")
+            new GenericContainer<>("pingcap/tidb:v6.1.0")
                     .withExposedPorts(TIDB_PORT)
                     .withFileSystemBind("src/test/resources/config/tidb.toml", "/tidb.toml")
                     .withCommand(