From 98e2cca800f9e815120a87f8f84a6018eba13892 Mon Sep 17 00:00:00 2001 From: Kunni Date: Fri, 18 Aug 2023 11:06:49 +0800 Subject: [PATCH] [test] Fix TiDBE2eITCase by updating the container version to avoid `tikv disk full` failure (#2402) (cherry picked from commit 8098c82c52bbb4841145f6fda9ca6a9f868a9486) --- .../com/ververica/cdc/connectors/tests/TiDBE2eITCase.java | 6 +++--- .../com/ververica/cdc/connectors/tidb/TiDBTestBase.java | 6 +++--- 2 files changed, 6 insertions(+), 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 index fefba8e36..5a117cc1b 100644 --- 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 index eac81b5aa..c6a5a4fcc 100644 --- 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(