chore(cubestore): Upgrade DF: Fix various problems with compaction.

Author: srh

rust/cubestore/cubestore/src/store/compaction.rs

@@ -1395,12 +1395,13 @@ pub async fn merge_chunks(
             .iter()
             .map(|aggr_col| aggr_col.aggregate_expr(&res.schema()))
             .collect::<Result<Vec<_>, _>>()?;
+        let aggregates_len = aggregates.len();
 
         res = Arc::new(AggregateExec::try_new(
             AggregateMode::Final,
-            PhysicalGroupBy::new(groups, Vec::new(), Vec::new()),
+            PhysicalGroupBy::new_single(groups),
             aggregates,
-            Vec::new(),
+            vec![None; aggregates_len],
             res.clone(),
             schema,
         )?);

rust/cubestore/cubestore/src/table/parquet.rs

@@ -90,7 +90,7 @@ pub struct ParquetTableStore {
 
 impl ParquetTableStore {
     pub fn read_columns(&self, path: &str) -> Result<Vec<RecordBatch>, CubeError> {
-        let builder = ParquetRecordBatchReaderBuilder::try_new(File::create_new(path)?)?;
+        let builder = ParquetRecordBatchReaderBuilder::try_new(File::open(path)?)?;
         let mut r = builder.with_batch_size(self.row_group_size).build()?;
         let mut batches = Vec::new();
         for b in r {