[hudi] branch master updated: [MINOR] Update operator name for compact&clustering test class (#9583)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 6f2e19d933c [MINOR] Update operator name for compact&clustering test 
class (#9583)
6f2e19d933c is described below

commit 6f2e19d933cdd086a1220824bffe6e28b7a50174
Author: hehuiyuan <471627...@qq.com>
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");