remove printlns

src/daft-local-execution/src/intermediate_ops/hash_join_probe.rs

@@ -112,7 +112,6 @@ impl IntermediateOperator for HashJoinProbeOperator {
         input: &PipelineResultType,
         state: Option<&mut Box<dyn IntermediateOperatorState>>,
     ) -> DaftResult<IntermediateOperatorResult> {
-        println!("HashJoinProbeOperator::execute: idx: {}", idx);
         match idx {
             0 => {
                 let state = state

src/daft-local-execution/src/intermediate_ops/intermediate_op.rs

@@ -138,7 +138,6 @@ impl IntermediateNode {
         };
 
         for (idx, mut receiver) in receivers.into_iter().enumerate() {
-            println!("idx: {}", idx);
             let mut buffer = OperatorBuffer::new(morsel_size);
             while let Some(morsel) = receiver.recv().await {
                 if morsel.should_broadcast() {

src/daft-local-execution/src/sinks/hash_join_build.rs

@@ -95,14 +95,14 @@ impl BlockingSink for HashJoinBuildSink {
         self.probe_table_state.add_tables(input)?;
         Ok(BlockingSinkStatus::NeedMoreInput)
     }
+
     fn finalize(&mut self) -> DaftResult<Option<PipelineResultType>> {
         self.probe_table_state.finalize()?;
         if let ProbeTableState::Done {
             probe_table,
             tables,
         } = &self.probe_table_state
         {
-            println!("HashJoinBuildSink::finalize: table_len: {}", tables.len());
             Ok(Some((probe_table.clone(), tables.clone()).into()))
         } else {
             panic!("finalize should only be called after the probe table is built")