From f024f13f6fcc4845af4184420235c884ecf180de 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 975e98eb39..48fc2df368 100644 --- a/crates/core/src/operations/write.rs +++ b/crates/core/src/operations/write.rs @@ -578,7 +578,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)