This is an automated email from the ASF dual-hosted git repository.
lvyanquan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 25e986298 [hotfix][connect/mysql] Pin Percona Toolkit image for OSC
tests (#4571)
25e986298 is described below
commit 25e98629835360465b6cab220ef4d86c008af9f5
Author: yuxiqian <[email protected]>
AuthorDate: Fri Oct 9 17:56:06 2026 +0800
[hotfix][connect/mysql] Pin Percona Toolkit image for OSC tests (#4571)
---
.../source/MySqlOnLineSchemaMigrationITCase.java | 2 +-
.../connectors/mysql/source/MySqlOscITCase.java | 2 +-
.../MySqlOnLineSchemaMigrationSourceITCase.java | 2 +-
.../MySqlOnLineSchemaMigrationTableITCase.java | 2 +-
.../flink-connector-postgres-cdc/pom.xml | 8 -----
pom.xml | 40 +++++++++-------------
6 files changed, 21 insertions(+), 35 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationITCase.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationITCase.java
index 9b1cd77cc..862a9f735 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationITCase.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationITCase.java
@@ -82,7 +82,7 @@ class MySqlOnLineSchemaMigrationITCase extends
MySqlSourceTestBase {
private static final MySqlContainer MYSQL8_CONTAINER =
createMySqlContainer(MySqlVersion.V8_0,
"docker/server-gtids/expire-seconds/my.cnf");
- private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1";
+ private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1-4";
protected static final GenericContainer<?> PERCONA_TOOLKIT_CONTAINER =
createPerconaToolkitContainer();
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOscITCase.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOscITCase.java
index ccf86e4d5..152e2713d 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOscITCase.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOscITCase.java
@@ -64,7 +64,7 @@ import static
org.apache.flink.cdc.connectors.mysql.testutils.MySqSourceTestUtil
class MySqlOscITCase extends MySqlSourceTestBase {
private static final MySqlContainer MYSQL8_CONTAINER =
createMySqlContainer(MySqlVersion.V8_0);
- private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1";
+ private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1-4";
protected static final GenericContainer<?> PERCONA_TOOLKIT_CONTAINER =
createPerconaToolkitContainer();
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationSourceITCase.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationSourceITCase.java
index 145bf4c0e..be11dfcb9 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationSourceITCase.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationSourceITCase.java
@@ -77,7 +77,7 @@ class MySqlOnLineSchemaMigrationSourceITCase extends
MySqlSourceTestBase {
private static final String TEST_USER = "mysqluser";
private static final String TEST_PASSWORD = "mysqlpw";
- private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1";
+ private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1-4";
protected static final GenericContainer<?> PERCONA_TOOLKIT_CONTAINER =
createPerconaToolkitContainer();
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java
index 752b54f24..4b31181b0 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java
@@ -78,7 +78,7 @@ class MySqlOnLineSchemaMigrationTableITCase extends
MySqlSourceTestBase {
private static final String TEST_USER = "mysqluser";
private static final String TEST_PASSWORD = "mysqlpw";
- private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1";
+ private static final String PERCONA_TOOLKIT =
"perconalab/percona-toolkit:3.7.1-4";
protected static final GenericContainer<?> PERCONA_TOOLKIT_CONTAINER =
createPerconaToolkitContainer();
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/pom.xml
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/pom.xml
index ec73c783a..7a0cd2714 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/pom.xml
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/pom.xml
@@ -184,14 +184,6 @@ limitations under the License.
</exclusions>
</dependency>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-test-util</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
-
-
<!-- tests will have log4j as the default logging framework available
-->
</dependencies>
diff --git a/pom.xml b/pom.xml
index c38d9087a..a852a4f95 100644
--- a/pom.xml
+++ b/pom.xml
@@ -661,6 +661,23 @@ limitations under the License.
</rules>
</configuration>
</execution>
+ <execution>
+ <id>enforce-maven</id>
+ <goals>
+ <goal>enforce</goal>
+ </goals>
+ <configuration>
+ <rules>
+ <requireMavenVersion>
+ <!-- enforce at least mvn version 3.1.1
(see FLINK-12447) -->
+ <version>[3.1.1,)</version>
+ </requireMavenVersion>
+ <requireJavaVersion>
+ <version>${source.java.version}</version>
+ </requireJavaVersion>
+ </rules>
+ </configuration>
+ </execution>
</executions>
</plugin>
@@ -722,29 +739,6 @@ limitations under the License.
<generateBackupPoms>false</generateBackupPoms>
</configuration>
</plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-enforcer-plugin</artifactId>
- <executions>
- <execution>
- <id>enforce-maven</id>
- <goals>
- <goal>enforce</goal>
- </goals>
- <configuration>
- <rules>
- <requireMavenVersion>
- <!-- enforce at least mvn version 3.1.1
(see FLINK-12447) -->
- <version>[3.1.1,)</version>
- </requireMavenVersion>
- <requireJavaVersion>
- <version>${source.java.version}</version>
- </requireJavaVersion>
- </rules>
- </configuration>
- </execution>
- </executions>
- </plugin>
</plugins>
</build>
