fix partition

hubgeter · Nov 20, 2024 · acadae6 · acadae6
1 parent 7e7d836
commit acadae6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-core/src/main/java/org/apache/doris/datasource/maxcompute/source/MaxComputeScanNode.java b/...-core/src/main/java/org/apache/doris/datasource/maxcompute/source/MaxComputeScanNode.java
@@ -132,7 +132,7 @@ private static void addPartitionSplits(List<Split> result, Table odpsTable, Stri
         long modificationTime = odpsTable.getLastDataModifiedTime().getTime();
         // use '-1' to read whole partition, avoid expending too much time on calling table.getTotalRows()
         result.add(new MaxComputeSplit(VIRTUAL_SLICE_PART,
-                0, -1L, -1, modificationTime, null, Collections.emptyList(), null));
+                0, -1L, -1, modificationTime, null, Collections.emptyList(), partitionSpec));
     }
 
     private static void addBatchSplits(List<Split> result, Table odpsTable, long totalRows) {