[FLINK-17977] Improve checkpoint triggering log message

spotify · Jun 15, 2020 · 6045d2e · 6045d2e
1 parent f1e4211
commit 6045d2e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -672,7 +672,7 @@ private PendingCheckpoint createPendingCheckpoint(
  }
  }
 
- LOG.info("Triggering checkpoint {} @ {} for job {}.", checkpointID, timestamp, job);
+ LOG.info("Triggering checkpoint {} (type={}) @ {} for job {}.", checkpointID, checkpoint.getProps().getCheckpointType(), timestamp, job);
  return checkpoint;
  }