[Improve] Improve CheckpointCoordinator log error when report error f…

…rom task (apache#178)
EricJoy2048 · Jul 22, 2023 · 1023e15 · 1023e15
1 parent d6e9327
commit 1023e15
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...er/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java b/...er/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
@@ -321,7 +321,9 @@ public InvocationFuture<?>[] notifyTaskStart() {
 
     public void reportCheckpointErrorFromTask(String errorMsg) {
         handleCoordinatorError(
-                CheckpointCloseReason.CHECKPOINT_INSIDE_ERROR, new SeaTunnelException(errorMsg));
+                "report error from task",
+                new SeaTunnelException(errorMsg),
+                CheckpointCloseReason.CHECKPOINT_INSIDE_ERROR);
     }
 
     private void scheduleTriggerPendingCheckpoint(long delayMills) {