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(); }