Skip to content

Commit 723615b

Browse files
authored
[FLINK-39312][pipeline][hudi] Fix Hudi connector packaging to include flink-metrics-dropwizard dependency. (#4332)
1 parent 283edb6 commit 723615b

File tree

2 files changed

+0
-6
lines changed

2 files changed

+0
-6
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,6 @@ limitations under the License.
247247
<groupId>org.apache.flink</groupId>
248248
<artifactId>flink-metrics-dropwizard</artifactId>
249249
<version>${flink.version}</version>
250-
<scope>test</scope>
251250
</dependency>
252251
</dependencies>
253252

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -238,15 +238,13 @@ public void testSyncWholeDatabase() throws Exception {
238238
Path hudiCdcConnector = TestUtils.getResource("hudi-cdc-pipeline-connector.jar");
239239
Path hadoopJar = TestUtils.getResource("flink-shade-hadoop.jar");
240240
Path hadoopCompatibilityJar = TestUtils.getResource("flink-hadoop-compatibility.jar");
241-
Path dropMetricsJar = TestUtils.getResource("flink-metrics-dropwizard.jar");
242241
Path flinkParquet = TestUtils.getResource("flink-parquet.jar");
243242
JobID pipelineJobID =
244243
submitPipelineJob(
245244
pipelineJob,
246245
hudiCdcConnector,
247246
hadoopJar,
248247
hadoopCompatibilityJar,
249-
dropMetricsJar,
250248
flinkParquet);
251249
waitUntilJobRunning(pipelineJobID, Duration.ofSeconds(60));
252250
LOG.info("Pipeline job is running");
@@ -572,7 +570,6 @@ public void testStopAndRestartFromSavepoint() throws Exception {
572570
Path hudiHadoopCommonJar = TestUtils.getResource("hudi-hadoop-common.jar");
573571
Path hadoopJar = TestUtils.getResource("flink-shade-hadoop.jar");
574572
Path hadoopCompatibilityJar = TestUtils.getResource("flink-hadoop-compatibility.jar");
575-
Path dropMetricsJar = TestUtils.getResource("flink-metrics-dropwizard.jar");
576573
Path flinkParquet = TestUtils.getResource("flink-parquet.jar");
577574

578575
// Start the pipeline job
@@ -584,7 +581,6 @@ public void testStopAndRestartFromSavepoint() throws Exception {
584581
hudiHadoopCommonJar,
585582
hadoopJar,
586583
hadoopCompatibilityJar,
587-
dropMetricsJar,
588584
flinkParquet);
589585
waitUntilJobRunning(pipelineJobID1, Duration.ofSeconds(60));
590586

@@ -662,7 +658,6 @@ public void testStopAndRestartFromSavepoint() throws Exception {
662658
hudiHadoopCommonJar,
663659
hadoopJar,
664660
hadoopCompatibilityJar,
665-
dropMetricsJar,
666661
flinkParquet);
667662
waitUntilJobRunning(pipelineJobID2, Duration.ofSeconds(60));
668663
LOG.info("Job restarted from savepoint");

0 commit comments

Comments
 (0)