diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphHandler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphHandler.java index 4d03468272be5..5078153ca6e92 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphHandler.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphHandler.java @@ -86,8 +86,7 @@ public void reportInitializationMetrics( executionGraph.getCheckpointCoordinatorConfiguration(); if (checkpointConfig == null || !checkpointConfig.isCheckpointingEnabled()) { // TODO: Consider to support reporting initialization stats without checkpointing - log.debug( - "Ignoring reportInitializationMetrics if checkpoint coordinator is not present"); + log.debug("Ignoring reportInitializationMetrics if checkpointing is not present"); return; }