diff --git a/plugins/parquet/parquetembed.cpp b/plugins/parquet/parquetembed.cpp index 2f6c3afaae1..dabb7a4b82e 100644 --- a/plugins/parquet/parquetembed.cpp +++ b/plugins/parquet/parquetembed.cpp @@ -1884,7 +1884,8 @@ void ParquetDatasetBinder::executeAll() } } - if (--i % row_size != 0) + i--; + if (i % row_size != 0) { d_parquet->record_batch()->resize(i % row_size); writeRecordBatch();