This is an automated email from the ASF dual-hosted git repository.

suxiaogang223 pushed a commit to branch refact_reader_branch
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/refact_reader_branch by this 
push:
     new 5ddf3f26562 [fix](be) Align nullable parquet struct child slots
5ddf3f26562 is described below

commit 5ddf3f26562dd7727fbe1b0ad5270606285288ff
Author: Socrates <[email protected]>
AuthorDate: Fri May 29 10:36:42 2026 +0800

    [fix](be) Align nullable parquet struct child slots
    
    ### What problem does this PR solve?
    
    Issue Number: close #xxx
    
    Related PR: #xxx
    
    Problem Summary: Read scalar struct children as row-aligned slots so 
nullable parent struct rows keep child value buffers aligned.
    
    ### Release note
    
    None
    
    ### Check List (For Author)
    
    - Test: Manual test
        - Ran git diff --check. Fedora BE unit test validation follows with 
./run-be-ut.sh --run '--filter=ParquetColumnReaderTest.*'.
    - Behavior changed: No
    - Does this need documentation: No
---
 be/src/format/new_parquet/column_reader.cpp | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/be/src/format/new_parquet/column_reader.cpp 
b/be/src/format/new_parquet/column_reader.cpp
index 4d24100685e..143cddd831a 100644
--- a/be/src/format/new_parquet/column_reader.cpp
+++ b/be/src/format/new_parquet/column_reader.cpp
@@ -794,8 +794,7 @@ Status StructColumnReader::read(int64_t rows, 
MutableColumnPtr& column, int64_t*
         std::vector<NestedScalarBatch> child_batches(scalar_children.size());
         int64_t expected_rows = -1;
         for (size_t child_idx = 0; child_idx < scalar_children.size(); 
++child_idx) {
-            
RETURN_IF_ERROR(read_nested_scalar_batch(*scalar_children[child_idx], rows,
-                                                     
_nullable_definition_level,
+            
RETURN_IF_ERROR(read_nested_scalar_batch(*scalar_children[child_idx], rows, 0,
                                                      
&child_batches[child_idx]));
             if (expected_rows < 0) {
                 expected_rows = child_batches[child_idx].records_read;


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to