(paimon) branch master updated: [spark] Skip empty global index builds (#8202)

[lzljs3620320]

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

JingsongLi 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 9e6ffc80a1 [spark] Skip empty global index builds (#8202)
9e6ffc80a1 is described below

commit 9e6ffc80a17b1416e9996a994e45a04af29877ff
Author: Stefanietry <zhou1172026...@gmail.com>
AuthorDate: Thu Jun 11 13:33:00 2026 +0800

    [spark] Skip empty global index builds (#8202)
---
 .../paimon/spark/globalindex/DefaultGlobalIndexTopoBuilder.java  | 4 ++++
 .../test/java/org/apache/paimon/spark/SparkMultimodalITCase.java | 9 +++++++++
 2 files changed, 13 insertions(+)

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 afd954c39a..d0c91c7479 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,6 +116,10 @@ public class DefaultGlobalIndexTopoBuilder implements 
GlobalIndexTopologyBuilder
             }
         }
 
+        if (taskList.isEmpty()) {
+            return Collections.emptyList();
+        }
+
         List<byte[]> commitMessageBytes =
                 javaSparkContext
                         .parallelize(taskList, taskList.size())
diff --git 
a/paimon-spark/paimon-spark-ut/src/test/java/org/apache/paimon/spark/SparkMultimodalITCase.java
 
b/paimon-spark/paimon-spark-ut/src/test/java/org/apache/paimon/spark/SparkMultimodalITCase.java
index 4bd45f0079..3a03ea182e 100644
--- 
a/paimon-spark/paimon-spark-ut/src/test/java/org/apache/paimon/spark/SparkMultimodalITCase.java
+++ 
b/paimon-spark/paimon-spark-ut/src/test/java/org/apache/paimon/spark/SparkMultimodalITCase.java
@@ -113,6 +113,15 @@ public class SparkMultimodalITCase {
         spark.close();
 
         spark = builder.getOrCreate();
+        spark.sql(
+                "\n"
+                        + "CALL sys.create_global_index(\n"
+                        + "    `table` => 'my_db1.vector_test',\n"
+                        + "    `partitions` => \"date='20260421'\",\n"
+                        + "    `index_column` => 'embs',\n"
+                        + "    `index_type` => 'lumina-vector-ann',\n"
+                        + "    `options` => 'lumina.index.dimension=4'\n"
+                        + ");");
         spark.sql(
                 "\n"
                         + "CALL sys.create_global_index(\n"