[fix](multi-catalog)fix max compute null parts table read (#40046) (#40179)

bp #40046

Co-authored-by: slothever <18522955+wsjz@users.noreply.github.com>
This commit is contained in:
Mingyu Chen
2024-08-30 22:56:08 +08:00
committed by GitHub
parent d949df0c4f
commit e4c48cfec5

View File

@ -170,6 +170,9 @@ public class MaxComputeJniScanner extends JniScanner {
// query columns required non-null, when query partition table
pushDownColumns.add(session.getSchema().getColumn(0));
}
if (totalRows == 0) {
return;
}
arrowAllocator = new RootAllocator(Integer.MAX_VALUE);
curReader = session.openArrowRecordReader(start, totalRows, pushDownColumns, arrowAllocator);
remainBatchRows = totalRows;