[FLINK-26550][checkpoint] Correct the information of checkpoint failure

tongcheng-elong · Mar 10, 2022 · 254c918 · 254c918
1 parent 0318b26
commit 254c918
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java b/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
@@ -105,7 +105,7 @@ public void handleCheckpointException(
  updateStatsAfterCheckpointFailed(pendingCheckpointStats, statsTracker, exception);
 
  LOG.warn(
- "Failed to trigger checkpoint {} for job {}. ({} consecutive failed attempts so far)",
+ "Failed to trigger or complete checkpoint {} for job {}. ({} consecutive failed attempts so far)",
  checkpointId == UNKNOWN_CHECKPOINT_ID ? "UNKNOWN_CHECKPOINT_ID" : checkpointId,
  job,
  continuousFailureCounter.get(),