logs

Author: matthewgapp

datafusion/physical-plan/src/continuance.rs

@@ -102,7 +102,7 @@ impl ExecutionPlan for ContinuanceExec {
     }
 
     fn output_partitioning(&self) -> Partitioning {
-        Partitioning::UnknownPartitioning(1)
+        Partitioning::UnknownPartitioning(0)
     }
 
     fn maintains_input_order(&self) -> Vec<bool> {
@@ -135,6 +135,7 @@ impl ExecutionPlan for ContinuanceExec {
         partition: usize,
         context: Arc<TaskContext>,
     ) -> Result<SendableRecordBatchStream> {
+        println!("calling execute on ContinuanceExec");
         // Continuance streams must be the plan base.
         if partition != 0 {
             return Err(DataFusionError::Internal(format!(

datafusion/physical-plan/src/repartition/mod.rs

@@ -554,6 +554,8 @@ impl ExecutionPlan for RepartitionExec {
             partition
         );
 
+        println!("execute partition: {}", partition);
+
         // now return stream for the specified *output* partition which will
         // read from the channel
         let (_tx, mut rx, reservation) = state