[Improve][Zeta] Improve CheckpointCoordinator log error when report e…

…rror from task (#178) (#5134)
apache · Jul 24, 2023 · 2391135 · 2391135
1 parent 7519817
commit 2391135
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
@@ -346,7 +346,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) {