Skip to content

Commit b5666a1

Browse files
ion-elgrecortyler
authored andcommitted
fix, don't use wrapped partitions, since we also write with CDC later
1 parent 438a4c9 commit b5666a1

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

crates/core/src/operations/delete.rs

+3-1
Original file line numberDiff line numberDiff line change
@@ -148,9 +148,11 @@ async fn excute_non_empty_expr(
148148
let input_schema = snapshot.input_schema()?;
149149
let input_dfschema: DFSchema = input_schema.clone().as_ref().clone().try_into()?;
150150
let table_partition_cols = snapshot.metadata().partition_columns.clone();
151-
152151
let scan = DeltaScanBuilder::new(snapshot, log_store.clone(), &state)
153152
.with_files(rewrite)
153+
// Use input schema which doesn't wrap partition values, otherwise divide_by_partition_value won't work on UTF8 partitions
154+
// Since it can't fetch a scalar from a dictionary type
155+
.with_schema(snapshot.input_schema()?)
154156
.build()
155157
.await?;
156158
let scan = Arc::new(scan);

0 commit comments

Comments
 (0)