minor

Author: CTTY

crates/integrations/datafusion/src/physical_plan/commit.rs

@@ -196,7 +196,7 @@ impl ExecutionPlan for IcebergCommitExec {
 
             // Collect all data files from this partition's stream
             for mut batch_stream in batches {
-                while let Some(batch_result) = batch_stream.as_mut().next().await {
+                while let Some(batch_result) = batch_stream.next().await {
                     let batch = batch_result?;
 
                     let files_array = batch

crates/integrations/datafusion/src/physical_plan/write.rs

@@ -37,7 +37,7 @@ use datafusion::physical_plan::{
 use futures::StreamExt;
 use iceberg::arrow::schema_to_arrow_schema;
 use iceberg::spec::{
-    DataFileFormat, FormatVersion, PROPERTY_DEFAULT_FILE_FORMAT,
+    DataFileFormat, PROPERTY_DEFAULT_FILE_FORMAT,
     PROPERTY_DEFAULT_FILE_FORMAT_DEFAULT, serialize_data_file_to_json,
 };
 use iceberg::table::Table;