[hotfix][API/DataStream] Log the right syncDurationMillis time

snuyanzin · Aug 21, 2024 · 9399e66 · 9399e66
1 parent 56c8199
commit 9399e66
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java b/.../main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
@@ -760,6 +760,8 @@ private boolean takeSnapshotSync(
             checkpointStorage.clearCacheFor(checkpointId);
         }
 
+        checkpointMetrics.setSyncDurationMillis((System.nanoTime() - started) / 1_000_000);
+
         LOG.debug(
                 "{} - finished synchronous part of checkpoint {}. Alignment duration: {} ms, snapshot duration {} ms, is unaligned checkpoint : {}",
                 taskName,
@@ -768,7 +770,6 @@ private boolean takeSnapshotSync(
                 checkpointMetrics.getSyncDurationMillis(),
                 checkpointOptions.isUnalignedCheckpoint());
 
-        checkpointMetrics.setSyncDurationMillis((System.nanoTime() - started) / 1_000_000);
         return true;
     }