From 9fc119ef6c5f76523f8e6be730543d62c21f9594 Mon Sep 17 00:00:00 2001 From: Hu Shenggang Date: Wed, 3 Dec 2025 16:55:51 +0800 Subject: [PATCH] [fix](olap) Fix the incorrect row count set when reading pruned columns --- be/src/olap/rowset/segment_v2/column_reader.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/be/src/olap/rowset/segment_v2/column_reader.cpp b/be/src/olap/rowset/segment_v2/column_reader.cpp index 313ae7f3f37fe9..e26b478d87f92a 100644 --- a/be/src/olap/rowset/segment_v2/column_reader.cpp +++ b/be/src/olap/rowset/segment_v2/column_reader.cpp @@ -965,7 +965,7 @@ Status MapFileColumnIterator::next_batch(size_t* n, vectorized::MutableColumnPtr bool* has_null) { if (_reading_flag == ReadingFlag::SKIP_READING) { DLOG(INFO) << "Map column iterator column " << _column_name << " skip reading."; - dst->resize(*n); + dst->resize(dst->size() + *n); return Status::OK(); } @@ -1259,7 +1259,7 @@ Status StructFileColumnIterator::next_batch(size_t* n, vectorized::MutableColumn bool* has_null) { if (_reading_flag == ReadingFlag::SKIP_READING) { DLOG(INFO) << "Struct column iterator column " << _column_name << " skip reading."; - dst->resize(*n); + dst->resize(dst->size() + *n); return Status::OK(); } @@ -1519,7 +1519,7 @@ Status ArrayFileColumnIterator::next_batch(size_t* n, vectorized::MutableColumnP bool* has_null) { if (_reading_flag == ReadingFlag::SKIP_READING) { DLOG(INFO) << "Array column iterator column " << _column_name << " skip reading."; - dst->resize(*n); + dst->resize(dst->size() + *n); return Status::OK(); } @@ -1736,7 +1736,7 @@ Status FileColumnIterator::next_batch(size_t* n, vectorized::MutableColumnPtr& d bool* has_null) { if (_reading_flag == ReadingFlag::SKIP_READING) { DLOG(INFO) << "File column iterator column " << _column_name << " skip reading."; - dst->resize(*n); + dst->resize(dst->size() + *n); return Status::OK(); }