diff --git a/cpp/velox/operators/serializer/VeloxColumnarToRowConverter.cc b/cpp/velox/operators/serializer/VeloxColumnarToRowConverter.cc index 9a474f8141c..49fd05ffd43 100644 --- a/cpp/velox/operators/serializer/VeloxColumnarToRowConverter.cc +++ b/cpp/velox/operators/serializer/VeloxColumnarToRowConverter.cc @@ -69,7 +69,7 @@ void VeloxColumnarToRowConverter::refreshStates(facebook::velox::RowVectorPtr ro void VeloxColumnarToRowConverter::convert(std::shared_ptr cb, int64_t startRow) { auto veloxBatch = VeloxColumnarBatch::from(veloxPool_.get(), cb); - refreshStates(veloxBatch->getFlattenedRowVector(), startRow); + refreshStates(veloxBatch->getRowVector(), startRow); // Initialize the offsets_ , lengths_ lengths_.clear();