| commit | 212b82f00bc6fc1f453dbc702e970c780d4554f2 | [log] [tgz] |
|---|---|---|
| author | slothever <18522955+wsjz@users.noreply.github.com> | Fri Aug 30 14:48:27 2024 +0800 |
| committer | GitHub <noreply@github.com> | Fri Aug 30 14:48:27 2024 +0800 |
| tree | 40a576729d782e251f4c6a8d4d84ed6cc6b60e43 | |
| parent | 37c5848e7dd7718167e1e62e4cab06561d370282 [diff] |
[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
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 89c351f..9c76a33 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 @@ // 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;