fix

Author: JingsongLi

paimon-core/src/main/java/org/apache/paimon/globalindex/GlobalIndexScanner.java

@@ -83,7 +83,7 @@ public GlobalIndexScanner(
                     .computeIfAbsent(fieldId, k -> new HashMap<>())
                     .computeIfAbsent(indexType, k -> new HashMap<>())
                     .computeIfAbsent(
-                            new Range(meta.rowRangeStart(), meta.rowRangeStart()),
+                            new Range(meta.rowRangeStart(), meta.rowRangeEnd()),
                             k -> new ArrayList<>())
                     .add(indexFile);
         }

paimon-core/src/main/java/org/apache/paimon/table/source/VectorReadImpl.java

@@ -41,11 +41,12 @@
 
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.Comparator;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Optional;
 import java.util.Set;
-import java.util.stream.Collectors;
+import java.util.TreeSet;
 
 import static java.util.Collections.singletonList;
 import static org.apache.paimon.utils.ManifestReadThreadPool.randomlyExecuteSequentialReturn;
@@ -114,9 +115,10 @@ public GlobalIndexResult read(List<VectorSearchSplit> splits) {
 
     private Optional<RoaringNavigableMap64> preFilter(List<VectorSearchSplit> splits) {
         Set<IndexFileMeta> scalarIndexFiles =
-                splits.stream()
-                        .flatMap(split -> split.scalarIndexFiles().stream())
-                        .collect(Collectors.toSet());
+                new TreeSet<>(Comparator.comparing(IndexFileMeta::fileName));
+        for (VectorSearchSplit split : splits) {
+            scalarIndexFiles.addAll(split.scalarIndexFiles());
+        }
         if (scalarIndexFiles.isEmpty()) {
             return Optional.empty();
         }

paimon-core/src/main/java/org/apache/paimon/table/source/VectorSearchSplit.java

@@ -28,6 +28,7 @@
 import java.io.ObjectOutputStream;
 import java.io.Serializable;
 import java.util.List;
+import java.util.Objects;
 
 /** Split of vector search. */
 public class VectorSearchSplit implements Serializable {
@@ -95,4 +96,35 @@ private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundE
         this.vectorIndexFiles = serializer.deserializeList(view);
         this.scalarIndexFiles = serializer.deserializeList(view);
     }
+
+    @Override
+    public boolean equals(Object o) {
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        VectorSearchSplit that = (VectorSearchSplit) o;
+        return rowRangeStart == that.rowRangeStart
+                && rowRangeEnd == that.rowRangeEnd
+                && Objects.equals(vectorIndexFiles, that.vectorIndexFiles)
+                && Objects.equals(scalarIndexFiles, that.scalarIndexFiles);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(rowRangeStart, rowRangeEnd, vectorIndexFiles, scalarIndexFiles);
+    }
+
+    @Override
+    public String toString() {
+        return "VectorSearchSplit{"
+                + "rowRangeStart="
+                + rowRangeStart
+                + ", rowRangeEnd="
+                + rowRangeEnd
+                + ", vectorIndexFiles="
+                + vectorIndexFiles
+                + ", scalarIndexFiles="
+                + scalarIndexFiles
+                + '}';
+    }
 }