(paimon) branch master updated: [core] Fix RawFiles construction which results to duplicate primary keys in query results (#3158)

[lzljs3620320]

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 ed97bebcf [core] Fix RawFiles construction which results to duplicate 
primary keys in query results (#3158)
ed97bebcf is described below

commit ed97bebcffd62205fd68842e0d0eef91e47e7201
Author: zhourui999 <40812600+zhourui...@users.noreply.github.com>
AuthorDate: Sun Apr 7 11:10:57 2024 +0800

    [core] Fix RawFiles construction which results to duplicate primary keys in 
query results (#3158)
---
 .../apache/paimon/table/source/snapshot/SnapshotReaderImpl.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
 
b/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
index fe48557e3..cb3c9fc7e 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
@@ -291,9 +291,10 @@ public class SnapshotReaderImpl implements SnapshotReader {
                 for (SplitGenerator.SplitGroup splitGroup : splitGroups) {
                     List<DataFileMeta> dataFiles = splitGroup.files;
                     builder.withDataFiles(dataFiles);
-                    if (splitGroup.rawConvertible) {
-                        builder.rawFiles(convertToRawFiles(partition, bucket, 
dataFiles));
-                    }
+                    builder.rawFiles(
+                            splitGroup.rawConvertible
+                                    ? convertToRawFiles(partition, bucket, 
dataFiles)
+                                    : Collections.emptyList());
                     if (deletionVectors) {
                         builder.withDataDeletionFiles(
                                 getDeletionFiles(dataFiles, 
deletionIndexFile));