Merge pull request #393 from ukwa/checkpoint-success-stats-392

Only update last checkpoint stats if the checkpoint completed, for #392.
2026-09-24 14:45:56 +00:00 · 2021-05-28 14:20:06 +01:00
parent 699f107ccd 5caa83d327
commit 169b3cc8ab
1 changed files with 3 additions and 1 deletions
@@ -308,12 +308,14 @@ public class CheckpointService implements Lifecycle, ApplicationContextAware, Ha
            
            appCtx.publishEvent(new CheckpointSuccessEvent(this,
                    checkpointInProgress));
+            
+            // Record the stats associated with this successfully-completed checkpoint:
+            lastCheckpointSnapshot = controller.getStatisticsTracker().getSnapshot();
        } catch (Exception e) {
            checkpointFailed(e);
        } finally {
            checkpointInProgress.writeValidity(
                controller.getStatisticsTracker().getProgressStamp());
-            lastCheckpointSnapshot = controller.getStatisticsTracker().getSnapshot();
            // close (incl. release locks)
            long finishStart = System.currentTimeMillis();
            for (Checkpointable c : toCheckpoint.values()) {