github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[test] Fix TiDBE2eITCase by updating the container version to avoid `tikv disk full` failure (#2402)

Browse Source 
(cherry picked from commit 8098c82c52)
pull/2694/head
Kunni 1 year ago committed by Leonard Xu
parent 9205ac2f90
commit 98e2cca800
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File

6
flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/TiDBE2eITCase.java
Unescape Escape View File

@ -71,7 +71,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
@ClassRule @ClassRule
public static final GenericContainer<?> PD = public static final GenericContainer<?> PD =
new GenericContainer<>("pingcap/pd:v6.0.0") new GenericContainer<>("pingcap/pd:v6.1.0")
.withExposedPorts(PD_PORT) .withExposedPorts(PD_PORT)
.withFileSystemBind("src/test/resources/docker/tidb/pd.toml", "/pd.toml") .withFileSystemBind("src/test/resources/docker/tidb/pd.toml", "/pd.toml")
.withCommand( .withCommand(
@ -92,7 +92,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
@ClassRule @ClassRule
public static final GenericContainer<?> TIKV = public static final GenericContainer<?> TIKV =
new GenericContainer<>("pingcap/tikv:v6.0.0") new GenericContainer<>("pingcap/tikv:v6.1.0")
.withExposedPorts(TIKV_PORT) .withExposedPorts(TIKV_PORT)
.withFileSystemBind("src/test/resources/docker/tidb/tikv.toml", "/tikv.toml") .withFileSystemBind("src/test/resources/docker/tidb/tikv.toml", "/tikv.toml")
.withCommand( .withCommand(
@ -110,7 +110,7 @@ public class TiDBE2eITCase extends FlinkContainerTestEnvironment {
@ClassRule @ClassRule
public static final GenericContainer<?> TIDB = public static final GenericContainer<?> TIDB =
new GenericContainer<>("pingcap/tidb:v6.0.0") new GenericContainer<>("pingcap/tidb:v6.1.0")
.withExposedPorts(TIDB_PORT) .withExposedPorts(TIDB_PORT)
.withFileSystemBind("src/test/resources/docker/tidb/tidb.toml", "/tidb.toml") .withFileSystemBind("src/test/resources/docker/tidb/tidb.toml", "/tidb.toml")
.withCommand( .withCommand(

6
flink-connector-tidb-cdc/src/test/java/com/ververica/cdc/connectors/tidb/TiDBTestBase.java
Unescape Escape View File

@ -72,7 +72,7 @@ public class TiDBTestBase extends AbstractTestBase {
@ClassRule @ClassRule
public static final GenericContainer<?> PD = 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") .withFileSystemBind("src/test/resources/config/pd.toml", "/pd.toml")
.withFixedExposedPort(pdPort, PD_PORT_ORIGIN) .withFixedExposedPort(pdPort, PD_PORT_ORIGIN)
.withCommand( .withCommand(
@ -92,7 +92,7 @@ public class TiDBTestBase extends AbstractTestBase {
@ClassRule @ClassRule
public static final GenericContainer<?> TIKV = 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) .withFixedExposedPort(TIKV_PORT_ORIGIN, TIKV_PORT_ORIGIN)
.withFileSystemBind("src/test/resources/config/tikv.toml", "/tikv.toml") .withFileSystemBind("src/test/resources/config/tikv.toml", "/tikv.toml")
.withCommand( .withCommand(
@ -110,7 +110,7 @@ public class TiDBTestBase extends AbstractTestBase {
@ClassRule @ClassRule
public static final GenericContainer<?> TIDB = public static final GenericContainer<?> TIDB =
new GenericContainer<>("pingcap/tidb:v6.0.0") new GenericContainer<>("pingcap/tidb:v6.1.0")
.withExposedPorts(TIDB_PORT) .withExposedPorts(TIDB_PORT)
.withFileSystemBind("src/test/resources/config/tidb.toml", "/tidb.toml") .withFileSystemBind("src/test/resources/config/tidb.toml", "/tidb.toml")
.withCommand( .withCommand(

Write Preview
Loading…
Cancel
Save