diff --git a/rust/src/delta_datafusion.rs b/rust/src/delta_datafusion.rs index b1b31b133d..7627c24d73 100644 --- a/rust/src/delta_datafusion.rs +++ b/rust/src/delta_datafusion.rs @@ -377,21 +377,6 @@ impl TableProvider for DeltaTable { .physical_arrow_schema(self.object_store()) .await?; - let schema = Arc::new(ArrowSchema::new( - schema - .fields() - .iter() - .map(|field| match field.data_type() { - ArrowDataType::Timestamp(TimeUnit::Microsecond, tz) => ArrowField::new( - field.name().clone(), - ArrowDataType::Timestamp(TimeUnit::Nanosecond, tz.clone()), - field.is_nullable(), - ), - _ => field.clone(), - }) - .collect(), - )); - register_store(self, session.runtime_env().clone()); let filter_expr = conjunction(filters.iter().cloned())