From 2687eab8f0b49f410c49fac7771a8409722574cf Mon Sep 17 00:00:00 2001 From: Danny Chan Date: Wed, 23 Jun 2021 14:49:38 +0800 Subject: [PATCH] [HUDI-2054] Remove the duplicate name for flink write pipeline (#3135) --- .../src/main/java/org/apache/hudi/table/HoodieTableSink.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java b/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java index ae25644d1..d648bc081 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java +++ b/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java @@ -96,13 +96,11 @@ public class HoodieTableSink implements DynamicTableSink, SupportsPartitioning, // shuffle by fileId(bucket id) .keyBy(record -> record.getCurrentLocation().getFileId()) .transform("hoodie_stream_write", TypeInformation.of(Object.class), operatorFactory) - .name("uid_hoodie_stream_write") .setParallelism(numWriteTasks); if (StreamerUtil.needsAsyncCompaction(conf)) { return pipeline.transform("compact_plan_generate", TypeInformation.of(CompactionPlanEvent.class), new CompactionPlanOperator(conf)) - .name("uid_compact_plan_generate") .setParallelism(1) // plan generate must be singleton .rebalance() .transform("compact_task",