[hotfix] Changelog operator name to cross-partition-bucket-assigner

askwang · Aug 26, 2024 · 0c1da9f · 0c1da9f
1 parent 8a661eb
commit 0c1da9f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...link-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java b/...link-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java
@@ -112,7 +112,7 @@ public DataStreamSink<?> build(DataStream<InternalRow> input, @Nullable Integer
         DataStream<Tuple2<InternalRow, Integer>> bucketAssigned =
                 partitionByKeyHash
                         .transform(
-                                "dynamic-bucket-assigner",
+                                "cross-partition-bucket-assigner",
                                 rowWithBucketType,
                                 GlobalIndexAssignerOperator.forRowData(table))
                         .setParallelism(partitionByKeyHash.getParallelism());