This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new e4c48cfec5e [fix](multi-catalog)fix max compute null parts table read
(#40046) (#40179)
e4c48cfec5e is described below
commit e4c48cfec5eed4d4f1fcbc7cd3529f3730c5a0c0
Author: Mingyu Chen <[email protected]>
AuthorDate: Fri Aug 30 22:56:08 2024 +0800
[fix](multi-catalog)fix max compute null parts table read (#40046) (#40179)
bp #40046
Co-authored-by: slothever <[email protected]>
---
.../main/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 6a441a69293..515ef8f401b 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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
