This is an automated email from the ASF dual-hosted git repository.
kunni 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 723615b66 [FLINK-39312][pipeline][hudi] Fix Hudi connector packaging
to include flink-metrics-dropwizard dependency. (#4332)
723615b66 is described below
commit 723615b66af28b2ee573e7f8db0bf5f03a6de354
Author: Shuo Cheng <[email protected]>
AuthorDate: Tue Mar 24 20:30:20 2026 +0800
[FLINK-39312][pipeline][hudi] Fix Hudi connector packaging to include
flink-metrics-dropwizard dependency. (#4332)
---
.../flink-cdc-pipeline-connector-hudi/pom.xml | 1 -
.../org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java | 5 -----
2 files changed, 6 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml
index 3ad7c92b5..57ac06f69 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml
@@ -247,7 +247,6 @@ limitations under the License.
<groupId>org.apache.flink</groupId>
<artifactId>flink-metrics-dropwizard</artifactId>
<version>${flink.version}</version>
- <scope>test</scope>
</dependency>
</dependencies>
diff --git
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java
index d1838041d..c0c07434a 100644
---
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java
+++
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java
@@ -238,7 +238,6 @@ public class MySqlToHudiE2eITCase extends
PipelineTestEnvironment {
Path hudiCdcConnector =
TestUtils.getResource("hudi-cdc-pipeline-connector.jar");
Path hadoopJar = TestUtils.getResource("flink-shade-hadoop.jar");
Path hadoopCompatibilityJar =
TestUtils.getResource("flink-hadoop-compatibility.jar");
- Path dropMetricsJar =
TestUtils.getResource("flink-metrics-dropwizard.jar");
Path flinkParquet = TestUtils.getResource("flink-parquet.jar");
JobID pipelineJobID =
submitPipelineJob(
@@ -246,7 +245,6 @@ public class MySqlToHudiE2eITCase extends
PipelineTestEnvironment {
hudiCdcConnector,
hadoopJar,
hadoopCompatibilityJar,
- dropMetricsJar,
flinkParquet);
waitUntilJobRunning(pipelineJobID, Duration.ofSeconds(60));
LOG.info("Pipeline job is running");
@@ -572,7 +570,6 @@ public class MySqlToHudiE2eITCase extends
PipelineTestEnvironment {
Path hudiHadoopCommonJar =
TestUtils.getResource("hudi-hadoop-common.jar");
Path hadoopJar = TestUtils.getResource("flink-shade-hadoop.jar");
Path hadoopCompatibilityJar =
TestUtils.getResource("flink-hadoop-compatibility.jar");
- Path dropMetricsJar =
TestUtils.getResource("flink-metrics-dropwizard.jar");
Path flinkParquet = TestUtils.getResource("flink-parquet.jar");
// Start the pipeline job
@@ -584,7 +581,6 @@ public class MySqlToHudiE2eITCase extends
PipelineTestEnvironment {
hudiHadoopCommonJar,
hadoopJar,
hadoopCompatibilityJar,
- dropMetricsJar,
flinkParquet);
waitUntilJobRunning(pipelineJobID1, Duration.ofSeconds(60));
@@ -662,7 +658,6 @@ public class MySqlToHudiE2eITCase extends
PipelineTestEnvironment {
hudiHadoopCommonJar,
hadoopJar,
hadoopCompatibilityJar,
- dropMetricsJar,
flinkParquet);
waitUntilJobRunning(pipelineJobID2, Duration.ofSeconds(60));
LOG.info("Job restarted from savepoint");
