diff --git a/src/writer.rs b/src/writer.rs index 61ee078..fa56854 100644 --- a/src/writer.rs +++ b/src/writer.rs @@ -369,7 +369,7 @@ impl DataWriter { pub fn update_schema(&mut self, table: &DeltaTable) -> Result> { let metadata = table.metadata().unwrap(); let schema: ArrowSchema = - >::try_from(&table.schema().unwrap())?; + >::try_from(table.schema().unwrap())?; let schema_updated = self.arrow_schema_ref.as_ref() != &schema || self.partition_columns != metadata.partition_columns;