From 3f2e94b8a53a1c78ce0fb82953d25c10b6f050f0 Mon Sep 17 00:00:00 2001
From: Micah Wylde <micah@arroyo.systems>
Date: Wed, 17 Jul 2024 15:52:15 -0700
Subject: [PATCH] Fix checkpoint cleanup failure (#688) (#689)

---
 crates/arroyo-state/src/parquet.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/crates/arroyo-state/src/parquet.rs b/crates/arroyo-state/src/parquet.rs
index d7974b1ce..ef4312385 100644
--- a/crates/arroyo-state/src/parquet.rs
+++ b/crates/arroyo-state/src/parquet.rs
@@ -257,14 +257,14 @@ impl ParquetBackend {
         let storage_client = get_storage_provider().await?;
 
         for epoch_to_remove in old_min_epoch..new_min_epoch {
-            let Some(metadata) =
+            let Some(operator_metadata) =
                 Self::load_operator_metadata(&job_id, &operator_id, epoch_to_remove).await?
             else {
                 continue;
             };
 
             // delete any files that are not in the new min epoch
-            for file in metadata
+            for file in operator_metadata
                 .table_checkpoint_metadata
                 .iter()
                 // TODO: factor this out