We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 28f1fb4 commit 48f831aCopy full SHA for 48f831a
kernel/src/actions/visitors.rs
@@ -559,6 +559,8 @@ impl CheckpointVisitor<'_> {
559
fn is_expired_tombstone<'a>(&self, i: usize, getter: &'a dyn GetData<'a>) -> DeltaResult<bool> {
560
// Ideally this should never be zero, but we are following the same behavior as Delta
561
// Spark and the Java Kernel.
562
+ // Note: When remove.deletion_timestamp is not present (defaulting to 0), the remove action
563
+ // will be excluded from the checkpoint file as it will be treated as expired.
564
let mut deletion_timestamp: i64 = 0;
565
if let Some(ts) = getter.get_opt(i, "remove.deletionTimestamp")? {
566
deletion_timestamp = ts;
0 commit comments