chore: cargo fix

Author: ovr

datafusion/src/datasource/parquet.rs

@@ -150,7 +150,6 @@ mod tests {
     use super::*;
     use arrow::array::{
         BinaryArray, BooleanArray, Float32Array, Float64Array, Int32Array,
-        TimestampNanosecondArray,
     };
     use arrow::record_batch::RecordBatch;
     use futures::StreamExt;

datafusion/src/execution/context.rs

@@ -559,7 +559,7 @@ impl ExecutionContext {
                     let handle: JoinHandle<Result<()>> = task::spawn(async move {
                         stream
                             .map(|batch| writer.write(&batch?))
-                            .try_collect()
+                            .try_collect::<()>()
                             .await
                             .map_err(DataFusionError::from)?;
                         writer.close().map_err(DataFusionError::from).map(|_| ())