clippy

Author: Rickard Lundin

src/chunked/arrow_converter.rs

@@ -236,11 +236,13 @@ impl<'a> Converter<'a> for Slice2Arrow<'a> {
     }
 
     fn setup(&mut self) -> (Sender<RecordBatch>, JoinHandle<Result<Stats>>) {
-        output_factory(
+        let o=output_factory(
             self.target.clone(),
             self.masterbuilders.schema_factory(),
             self.masterbuilders.outfile.clone(),
-        )
+        );
+        self.masterbuilders.sender=Some(o.0.clone());
+        o
     }
 
     fn shutdown(&mut self) {

src/chunked/threaded_file_output.rs

@@ -137,6 +137,7 @@ impl arrow_file_output for parquet_file_out {
                 builder_write_duration: Default::default(),
             })
         });
+        self.sender=Some(sender.clone());
         (sender, t)
     }
 }
@@ -201,6 +202,7 @@ impl arrow_file_output for ipc_file_out {
                 builder_write_duration: Default::default(),
             })
         });
+        self.sender=Some(sender.clone());
         (sender, t)
     }
 }