for test

Author: zhyass

src/query/service/src/interpreters/interpreter_table_recluster.rs

@@ -368,6 +368,7 @@ impl ReclusterTableInterpreter {
                         }),
                         plan.output_schema()?.as_ref(),
                     )?;
+                    log::warn!("hilbert recluster expr: {:?}", expr);
                     plan = Box::new(PhysicalPlan::Exchange(Exchange {
                         plan_id: 0,
                         input: plan,

src/query/service/src/pipelines/processors/transforms/transform_partition_collect.rs

@@ -327,12 +327,22 @@ impl Processor for TransformHilbertPartitionCollect {
                 if let Some((partition_id, data_block)) = self.immediate_output_blocks.pop() {
                     self.restored_data_blocks = self.buffer.restore_by_id(partition_id).await?;
                     self.restored_data_blocks.push(data_block);
+                    log::warn!(
+                        "flush processor id: {}, partition id: {}",
+                        self.processor_id,
+                        partition_id
+                    );
                     self.state = State::Concat;
                 }
             }
             State::Spill => self.buffer.spill().await?,
             State::Restore => {
                 let (id, blocks) = self.buffer.restore_with_id().await?;
+                log::warn!(
+                    "restore processor id: {}, partition id: {}",
+                    self.processor_id,
+                    id
+                );
                 if !blocks.is_empty() {
                     self.restored_data_blocks = blocks;
                     self.state = State::Concat;