Skip to content

feat: add ReachableFileCleanup to expire snapshots#592

Merged
wgtmac merged 7 commits intoapache:mainfrom
shangxinli:expire-snapshots-file-cleanup
Apr 24, 2026
Merged

feat: add ReachableFileCleanup to expire snapshots#592
wgtmac merged 7 commits intoapache:mainfrom
shangxinli:expire-snapshots-file-cleanup

Conversation

@shangxinli
Copy link
Copy Markdown
Contributor

@shangxinli shangxinli commented Mar 16, 2026

Summary

  • Implement the file cleanup logic missing from expire snapshots (feat: support expire snapshots #490 noted "TODO: File recycling will be added in a followup PR")
  • Port the "reachable file cleanup" strategy from Java's ReachableFileCleanup
  • Single-threaded implementation; multi-threaded and incremental cleanup as TODOs

@shangxinli shangxinli force-pushed the expire-snapshots-file-cleanup branch 2 times, most recently from 596c5d2 to d3df6e3 Compare March 16, 2026 18:26
Copy link
Copy Markdown
Member

@wgtmac wgtmac left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Note: This review was generated by Gemini.

Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Copy link
Copy Markdown
Member

@wgtmac wgtmac left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Note: This review was generated by Gemini.

Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
@shangxinli shangxinli force-pushed the expire-snapshots-file-cleanup branch 2 times, most recently from 4f36084 to 1ebc015 Compare March 26, 2026 17:34
@shangxinli
Copy link
Copy Markdown
Contributor Author

shangxinli commented Mar 31, 2026

@wgtmac, made the change. Can you have a look?

@wgtmac
Copy link
Copy Markdown
Member

wgtmac commented Mar 31, 2026

I'm on the way :)

Comment thread src/iceberg/update/expire_snapshots.h Outdated
Comment thread src/iceberg/update/expire_snapshots.h Outdated
Comment thread src/iceberg/update/expire_snapshots.h Outdated
Comment thread src/iceberg/update/expire_snapshots.h Outdated
Comment thread src/iceberg/update/expire_snapshots.h Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
@shangxinli
Copy link
Copy Markdown
Contributor Author

@wgtmac do you have time to have another look?

Copy link
Copy Markdown
Member

@wgtmac wgtmac left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Codex review comments for the two issues found in expire snapshots cleanup.

Comment thread src/iceberg/update/expire_snapshots.cc Outdated
Comment thread src/iceberg/update/expire_snapshots.cc Outdated
shangxinli and others added 7 commits April 22, 2026 16:43
Implement the file cleanup logic that was missing from the expire
snapshots feature (the original PR noted "TODO: File recycling will
be added in a followup PR").

Port the "reachable file cleanup" strategy from Java's
ReachableFileCleanup, following the same phased approach:

Phase 1: Collect manifest paths from expired and retained snapshots
Phase 2: Prune manifests still referenced by retained snapshots
Phase 3: Find data files only in manifests being deleted, subtract
         files still reachable from retained manifests (kAll only)
Phase 4: Delete orphaned manifest files
Phase 5: Delete manifest lists from expired snapshots
Phase 6: Delete expired statistics and partition statistics files

Key design decisions matching Java parity:
- Best-effort deletion: suppress errors on individual file deletions
  to avoid blocking metadata updates (Java suppressFailureWhenFinished)
- Branch/tag awareness: retained snapshot set includes all snapshots
  reachable from any ref (branch or tag), preventing false-positive
  deletions of files still referenced by non-main branches
- Data file safety: only delete data files from manifests that are
  themselves being deleted, then subtract any files still reachable
  from retained manifests (two-pass approach from ReachableFileCleanup)
- Respect CleanupLevel: kNone skips all, kMetadataOnly skips data
  files, kAll cleans everything
- FileIO abstraction: uses FileIO::DeleteFile for filesystem
  compatibility (S3, HDFS, local), with custom DeleteWith() override
- Statistics cleanup via snapshot ID membership in retained set

TODOs for follow-up:
- Multi-threaded file deletion (Java uses Tasks.foreach with executor)
- IncrementalFileCleanup strategy for linear ancestry optimization
  (Java uses this when no branches/cherry-picks involved)
- Fix O(M*S) I/O: Pre-cache ManifestFile objects in manifest_cache_ during
  Phase 1 (ReadManifestsForSnapshot), eliminating repeated manifest list
  reads in FindDataFilesToDelete.

- Fix storage leak: Use LiveEntries() instead of Entries() to match Java's
  ManifestFiles.readPaths behavior (only ADDED/EXISTING entries).

- Fix data loss risk: When reading a retained manifest fails, abort data
  file deletion entirely instead of silently continuing. Java retries and
  throws on failure here.

- Fix statistics file deletion: Use path-based set difference instead of
  snapshot_id-only check, preventing erroneous deletion of statistics files
  shared across snapshots.

- Remove goto anti-pattern: Extract ManifestFile lookup into
  MakeManifestReader() helper and use manifest_cache_ for direct lookup.

- Improve API: FindDataFilesToDelete now returns
  Result<unordered_set<string>> instead of using a mutable out-parameter.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Mirror Java's file cleanup class hierarchy for expire snapshots:
- Add abstract FileCleanupStrategy with shared DeleteFile() and
  ExpiredStatisticsFilePaths() utilities (path-based set difference)
- Add ReachableFileCleanup concrete class owning manifest_cache_,
  ReadManifestsForSnapshot(), and FindDataFilesToDelete()
- Move MakeManifestReader() to a free function in anonymous namespace
  using ICEBERG_ASSIGN_OR_RAISE
- Remove cleanup-specific private methods and manifest_cache_ from
  ExpireSnapshots class; Finalize() now delegates to the strategy
- Clear apply_result_ after consumption in Finalize()
- Rename DeleteFilePath to DeleteFile; use std::ignore for FileIO return
- Remove manifest_list.h and manifest_reader.h from the header
… stats file deletion

P0: ReadManifestsForSnapshot now returns bool. If any retained snapshot's
manifest list cannot be read, phases 2-4 (manifest and data file deletion)
are skipped entirely. An incomplete retained set makes it unsafe to compute
manifests_to_delete, as manifests still referenced by unreadable snapshots
would be wrongly included. This matches Java's throwFailureWhenFinished
behavior in ReachableFileCleanup. Manifest list deletion (phase 5) is
unaffected since it is keyed on expired snapshots only.

P1: Remove physical statistics and partition-statistics file deletion (the
former phase 6). RemoveStatistics/RemovePartitionStatistics are still not
called in RemoveSnapshots (the TODO in table_metadata.cc), so the committed
metadata still references those files after they would be deleted on disk.
Deletion is deferred until the metadata-level removal is wired in, at which
point the two operations can be kept in sync.
@wgtmac wgtmac force-pushed the expire-snapshots-file-cleanup branch from 59dfa56 to c9c1878 Compare April 24, 2026 09:38
Copy link
Copy Markdown
Member

@wgtmac wgtmac left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @shangxinli for adding this!

@wgtmac wgtmac changed the title feat: Add file cleanup for expire snapshots feat: add ReachableFileCleanup to expire snapshots Apr 24, 2026
@wgtmac wgtmac merged commit b94fa7c into apache:main Apr 24, 2026
13 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants