From e4c48cfec5eed4d4f1fcbc7cd3529f3730c5a0c0 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Fri, 30 Aug 2024 22:56:08 +0800 Subject: [PATCH] [fix](multi-catalog)fix max compute null parts table read (#40046) (#40179) bp #40046 Co-authored-by: slothever <18522955+wsjz@users.noreply.github.com> --- .../java/org/apache/doris/maxcompute/MaxComputeJniScanner.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java b/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java index 6a441a6929..515ef8f401 100644 --- a/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java +++ b/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java @@ -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;