You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2024/08/26 09:38:51 UTC
(paimon) branch master updated: [hotfix] Changelog operator name to cross-partition-bucket-assigner
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 0c1da9f85 [hotfix] Changelog operator name to cross-partition-bucket-assigner
0c1da9f85 is described below
commit 0c1da9f85c38990705697f89119d3ed65a182954
Author: Jingsong <ji...@gmail.com>
AuthorDate: Mon Aug 26 17:38:21 2024 +0800
[hotfix] Changelog operator name to cross-partition-bucket-assigner
---
.../org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java
index f4da37072..26e080c32 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java
@@ -112,7 +112,7 @@ public class GlobalDynamicBucketSink extends FlinkWriteSink<Tuple2<InternalRow,
DataStream<Tuple2<InternalRow, Integer>> bucketAssigned =
partitionByKeyHash
.transform(
- "dynamic-bucket-assigner",
+ "cross-partition-bucket-assigner",
rowWithBucketType,
GlobalIndexAssignerOperator.forRowData(table))
.setParallelism(partitionByKeyHash.getParallelism());