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 b3e4d82175 [flink] forward parallelism of ReadOperator for clustering
(#6619)
b3e4d82175 is described below
commit b3e4d821752a6ba69cb5f65b9df01a6c4345495f
Author: LsomeYeah <[email protected]>
AuthorDate: Mon Nov 17 18:02:15 2025 +0800
[flink] forward parallelism of ReadOperator for clustering (#6619)
---
.../org/apache/paimon/flink/cluster/IncrementalClusterSplitSource.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/cluster/IncrementalClusterSplitSource.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/cluster/IncrementalClusterSplitSource.java
index 132dab660e..25fe923df5 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/cluster/IncrementalClusterSplitSource.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/cluster/IncrementalClusterSplitSource.java
@@ -116,7 +116,8 @@ public class IncrementalClusterSplitSource extends
AbstractNonCoordinatedSource<
table.fullName(), partitionSpec),
InternalTypeInfo.of(
LogicalTypeConversion.toLogicalType(table.rowType())),
- new ReadOperator(table::newRead, null, null)),
+ new ReadOperator(table::newRead, null, null))
+ .setParallelism(partitioned.getParallelism()),
source.forward()
.transform(
"Remove files to be clustered",
