From 8e611cb0d5a20657864c108a072ea539c155e366 Mon Sep 17 00:00:00 2001 From: Siddharth kumar Date: Tue, 10 Sep 2024 02:32:03 +0530 Subject: [PATCH] fix(rust): scan schema fix for predicate --- crates/core/src/operations/write.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/core/src/operations/write.rs b/crates/core/src/operations/write.rs index b3f0f30c1b..00be7be869 100644 --- a/crates/core/src/operations/write.rs +++ b/crates/core/src/operations/write.rs @@ -561,7 +561,7 @@ async fn execute_non_empty_expr( let input_dfschema: DFSchema = df_schema.as_ref().clone().try_into()?; let scan_config = DeltaScanConfigBuilder::new() - .with_schema(df_schema) + .with_schema(snapshot.input_schema()?) .build(snapshot)?; let scan = DeltaScanBuilder::new(snapshot, log_store.clone(), &state)