fix: allow missing file stats in log replay

delta-io · Aug 14, 2024 · e688ad4 · e688ad4
1 parent fd4ff7f
commit e688ad4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/crates/core/src/kernel/snapshot/replay.rs b/crates/core/src/kernel/snapshot/replay.rs
@@ -108,8 +108,9 @@ fn map_batch(
 ) -> DeltaResult<RecordBatch> {
     let mut new_batch = batch.clone();
 
+    let stats = ex::extract_and_cast_opt::<StringArray>(&batch, "add.stats");
     let stats_parsed_col = ex::extract_and_cast_opt::<StructArray>(&batch, "add.stats_parsed");
-    if stats_parsed_col.is_none() {
+    if stats_parsed_col.is_none() && stats.is_some() {
         new_batch = parse_stats(new_batch, stats_schema, config)?;
     }