Fix checkpoint cleanup failure (ArroyoSystems#688) (ArroyoSystems#689)

axodotdev · Jul 17, 2024 · 3f2e94b · 3f2e94b
1 parent e71118e
commit 3f2e94b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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