1

apache · Sep 18, 2024 · 41bbbfc · 41bbbfc
1 parent 113822e
commit 41bbbfc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/utils/Projection.java b/paimon-common/src/main/java/org/apache/paimon/utils/Projection.java
@@ -310,8 +310,11 @@ public Projection complement(int fieldsNumber) {
 
         @Override
         public int[] toTopLevelIndexes() {
-            // todo: fix it usage
-            return Arrays.stream(projection).mapToInt(arr -> arr[0]).toArray();
+            return Arrays.stream(projection)
+                    .map(arr -> arr[0])
+                    .distinct()
+                    .mapToInt(Integer::intValue)
+                    .toArray();
         }
 
         @Override

diff --git a/...park/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonQueryTest.scala b/...park/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonQueryTest.scala
@@ -194,6 +194,7 @@ class PaimonQueryTest extends PaimonSparkTestBase {
 
       sql("""
             |SELECT
+            |    course.grade,
             |    name,
             |    course.course_name
             |FROM