This is an automated email from the ASF dual-hosted git repository. kunni pushed a commit to branch FLINK-38730-copy in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 259571e7fd3e41d0b242b6b594fee3773cb77a8a Author: lvyanquan <[email protected]> AuthorDate: Mon Dec 8 11:42:45 2025 +0800 Address comment. --- .../flink-cdc-pipeline-connector-paimon/pom.xml | 2 +- .../flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java | 5 ++++- .../cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java | 5 ++++- pom.xml | 1 + 4 files changed, 10 insertions(+), 3 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml index d3618805e..c17b7f953 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml @@ -32,7 +32,7 @@ limitations under the License. <paimon.version>1.2.0</paimon.version> <hadoop.version>2.8.5</hadoop.version> <hive.version>2.3.9</hive.version> - <mockito.version>3.4.6</mockito.version> + <mockito.version>3.12.4</mockito.version> </properties> <dependencies> diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java index e2b4f6fb3..1534ae4e8 100644 --- a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java +++ b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java @@ -403,7 +403,10 @@ public abstract class PipelineTestEnvironment extends TestLogger { } protected String getFlinkDockerImageTag() { - return String.format("flink:%s-scala_2.12", flinkVersion); + if (System.getProperty("java.specification.version").equals("17")) { + return String.format("flink:%s-scala_2.12-java17", flinkVersion); + } + return String.format("flink:%s-scala_2.12-java11", flinkVersion); } private ExecResult executeAndCheck(GenericContainer<?> container, String... command) { diff --git a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java index 095c5c23b..96173989c 100644 --- a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java +++ b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java @@ -308,7 +308,10 @@ public abstract class FlinkContainerTestEnvironment extends TestLogger { } private String getFlinkDockerImageTag() { - return String.format("flink:%s-scala_2.12", flinkVersion); + if (System.getProperty("java.specification.version").equals("17")) { + return String.format("flink:%s-scala_2.12-java17", flinkVersion); + } + return String.format("flink:%s-scala_2.12-java11", flinkVersion); } protected String getJdbcConnectorResourceName() { diff --git a/pom.xml b/pom.xml index 6a1ad440c..e788f9fe0 100644 --- a/pom.xml +++ b/pom.xml @@ -576,6 +576,7 @@ limitations under the License. --add-opens=java.sql/java.sql=ALL-UNNAMED --add-opens=java.base/java.nio=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED + --add-opens java.base/java.net=ALL-UNNAMED --add-exports=java.base/sun.nio.ch=ALL-UNNAMED </argLine> </configuration>
