[hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already.
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
index cf5e7b2..a51a63f 100644
--- 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
@@ -894,7 +894,7 @@
}
} else {
LOG.info(
- "Failed to trigger checkpoint for job {} since {}",
+ "Failed to trigger checkpoint for job {} because {}",
job,
throwable.getMessage());
}
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
index eb34ab7..a6874f1 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
@@ -91,9 +91,7 @@
try {
if (context.hasFinishedTasks() && !allowCheckpointsAfterTasksFinished) {
throw new CheckpointException(
- String.format(
- "some tasks of job %s has been finished, abort the checkpoint",
- jobId),
+ "Some tasks of the job have already finished and checkpointing with finished tasks is not enabled.",
CheckpointFailureReason.NOT_ALL_REQUIRED_TASKS_RUNNING);
}
