more logging

matthewgapp · matthewgapp · commit 285c360ba26e · 2023-09-17T10:24:31.000-07:00
diff --git a/datafusion/physical-plan/src/recursive_query.rs b/datafusion/physical-plan/src/recursive_query.rs
@@ -150,6 +150,7 @@ impl ExecutionPlan for RecursiveQueryExec {
         partition: usize,
         context: Arc<TaskContext>,
     ) -> Result<SendableRecordBatchStream> {
+        println!("recursive query exec execute");
         // All partitions must be coalesced before coming to RecursiveQueryExec.
         // TODO: we might be able to handle multiple partitions in the future.
         if partition != 0 {
@@ -306,6 +307,7 @@ impl RecursiveQueryStream {
             }
         }
 
+        println!("executing recursive term");
         self.recursive_stream =
             Some(self.recursive_term.execute(0, self.task_context.clone())?);
         self.poll_next(cx)

Original file line number	Diff line number	Diff line change
`@@ -150,6 +150,7 @@ impl ExecutionPlan for RecursiveQueryExec {`
`150`	`150`	`partition: usize,`
`151`	`151`	`context: Arc<TaskContext>,`
`152`	`152`	`) -> Result<SendableRecordBatchStream> {`
	`153`	`+ println!("recursive query exec execute");`
`153`	`154`	`// All partitions must be coalesced before coming to RecursiveQueryExec.`
`154`	`155`	`// TODO: we might be able to handle multiple partitions in the future.`
`155`	`156`	`if partition != 0 {`
`@@ -306,6 +307,7 @@ impl RecursiveQueryStream {`
`306`	`307`	`}`
`307`	`308`	`}`
`308`	`309`
	`310`	`+ println!("executing recursive term");`
`309`	`311`	`self.recursive_stream =`
`310`	`312`	`Some(self.recursive_term.execute(0, self.task_context.clone())?);`
`311`	`313`	`self.poll_next(cx)`