You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2024/09/03 08:13:29 UTC
(doris) 04/11: [fix](multi-catalog)fix max compute null parts table read (#40046)
This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit e22dfd0d22f7cd2e3fa6b788adebe0e672e553e9
Author: slothever <18...@users.noreply.github.com>
AuthorDate: Fri Aug 30 14:48:27 2024 +0800
[fix](multi-catalog)fix max compute null parts table read (#40046)
## Proposed changes
fix max compute null parts table read
if no any data in a part, we should make mc jni scanner return 0 rows
---
.../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 89c351f7343..9c76a330a64 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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org