diff --git a/query/src/sql/statements/value_source.rs b/query/src/sql/statements/value_source.rs
index be8ae47e0364..52a1e0e926f5 100644
--- a/query/src/sql/statements/value_source.rs
+++ b/query/src/sql/statements/value_source.rs
@@ -131,6 +131,8 @@ impl ValueSource {
                 for deser in desers.iter_mut().take(pop_count) {
                     deser.pop_data_value()?;
                 }
+                // rollback to get full data
+                reader.rollback_to_checkpoint()?;
                 skip_to_next_row(reader, 1)?;
 
                 // Parse from expression and append all columns.