[hotfix] Improve language for error message when checkpoint is declin…

…ed due to some tasks being finished already.
bbejeck · Sep 10, 2021 · ed3b613 · ed3b613
1 parent d79bb47
commit ed3b613
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
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
@@ -894,7 +894,7 @@ private void onTriggerFailure(@Nullable PendingCheckpoint checkpoint, Throwable
  }
  } else {
  LOG.info(
- "Failed to trigger checkpoint for job {} since {}",
+ "Failed to trigger checkpoint for job {} because {}",
  job,
  throwable.getMessage());
  }

diff --git a/...me/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java b/...me/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java
@@ -91,9 +91,7 @@ public CompletableFuture<CheckpointPlan> calculateCheckpointPlan() {
  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);
  }