From 2391135388c612b0bc0a6ae45e08afa9ceb0822d Mon Sep 17 00:00:00 2001
From: Jia Fan <fanjiaeminem@qq.com>
Date: Mon, 24 Jul 2023 10:52:50 +0800
Subject: [PATCH] [Improve][Zeta] Improve CheckpointCoordinator log error when
 report error from task (#178) (#5134)

---
 .../engine/server/checkpoint/CheckpointCoordinator.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
index 9bf0e770696..0f9e03df349 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
+++ b/seatunnel-engine/seatunnel-engine-server/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) {