fix(query): z

databendlabs · Jan 10, 2025 · e2c8675 · e2c8675
1 parent 898f429
commit e2c8675
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/...ce/src/pipelines/processors/transforms/aggregator/serde/transform_aggregate_serializer.rs b/...ce/src/pipelines/processors/transforms/aggregator/serde/transform_aggregate_serializer.rs
@@ -202,10 +202,14 @@ impl SerializeAggregateStream {
     }
 
     pub fn empty_block(bucket: isize, max_partition_count: usize) -> DataBlock {
-        DataBlock::empty_with_meta(AggregateSerdeMeta::create_agg_payload(
-            bucket,
-            max_partition_count,
-        ))
+        DataBlock::new_with_meta(
+            vec![],
+            1,
+            Some(AggregateSerdeMeta::create_agg_payload(
+                bucket,
+                max_partition_count,
+            )),
+        )
     }
 }
 

diff --git a/...pelines/processors/transforms/aggregator/serde/transform_exchange_aggregate_serializer.rs b/...pelines/processors/transforms/aggregator/serde/transform_exchange_aggregate_serializer.rs
@@ -158,7 +158,7 @@ impl BlockMetaTransform<ExchangeShuffleMeta> for TransformExchangeAggregateSeria
                         continue;
                     }
 
-                    let bucket = compute_block_number(bucket, max_partition_count)?;
+                    let block_number = compute_block_number(bucket, max_partition_count)?;
                     let stream = SerializeAggregateStream::create(
                         &self.params,
                         SerializePayload::AggregatePayload(p),
@@ -174,7 +174,7 @@ impl BlockMetaTransform<ExchangeShuffleMeta> for TransformExchangeAggregateSeria
                         }
                         c
                     };
-                    let c = serialize_block(bucket, c, &self.options)?;
+                    let c = serialize_block(block_number, c, &self.options)?;
                     serialized_blocks.push(FlightSerialized::DataBlock(c));
                 }
             };