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 773dcf66a7 [spark] Create global index topology update spark
parallelism (#7210)
773dcf66a7 is described below
commit 773dcf66a7a83c29ee6ca3a92b6cbf4d0026116d
Author: YeJunHao <[email protected]>
AuthorDate: Wed Feb 4 17:47:59 2026 +0800
[spark] Create global index topology update spark parallelism (#7210)
---
.../apache/paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java
index 6726caaae6..88a5dfc3b1 100644
---
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java
+++
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java
@@ -116,7 +116,7 @@ public class DefaultGlobalIndexTopoBuilder implements
GlobalIndexTopologyBuilder
List<byte[]> commitMessageBytes =
javaSparkContext
- .parallelize(taskList)
+ .parallelize(taskList, taskList.size())
.map(DefaultGlobalIndexTopoBuilder::buildIndex)
.collect();
return CommitMessageSerializer.deserializeAll(commitMessageBytes);
