This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 15ecee9674ec734cd54bd4ef8198ba3690cef1ee Author: hehuiyuan <[email protected]> AuthorDate: Fri Sep 1 09:42:36 2023 +0800 [MINOR] Update operator name for compact&clustering test class (#9583) --- .../org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java | 4 ++-- .../org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java index 18a8aebb8fd..4c817a7927a 100644 --- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java +++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java @@ -410,8 +410,8 @@ public class ITTestHoodieFlinkClustering { // keep pending clustering, not committing clustering dataStream .addSink(new DiscardingSink<>()) - .name("clustering_commit") - .uid("uid_clustering_commit") + .name("discarding-sink") + .uid("uid_discarding-sink") .setParallelism(1); env.execute("flink_hudi_clustering"); diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java index b032ad46765..ac2d93a7305 100644 --- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java +++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java @@ -175,8 +175,8 @@ public class ITTestHoodieFlinkCompactor { new CompactOperator(conf)) .setParallelism(FlinkMiniCluster.DEFAULT_PARALLELISM) .addSink(new CompactionCommitSink(conf)) - .name("clean_commits") - .uid("uid_clean_commits") + .name("compaction_commit") + .uid("uid_compaction_commit") .setParallelism(1); env.execute("flink_hudi_compaction"); @@ -256,8 +256,8 @@ public class ITTestHoodieFlinkCompactor { new CompactOperator(conf)) .setParallelism(FlinkMiniCluster.DEFAULT_PARALLELISM) .addSink(new CompactionCommitSink(conf)) - .name("clean_commits") - .uid("uid_clean_commits") + .name("compaction_commit") + .uid("uid_compaction_commit") .setParallelism(1); env.execute("flink_hudi_compaction");
