From ebe99f05881b170b05358864e601d3be3845ce75 Mon Sep 17 00:00:00 2001
From: Jia Fan <fanjiaeminem@qq.com>
Date: Sat, 22 Jul 2023 23:08:11 +0800
Subject: [PATCH] [Fix] Fix checkpoint error report without msg

---
 .../CheckpointErrorReportOperation.java          | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/operation/CheckpointErrorReportOperation.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/operation/CheckpointErrorReportOperation.java
index 75ec924b70a..967e1572311 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/operation/CheckpointErrorReportOperation.java
+++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/operation/CheckpointErrorReportOperation.java
@@ -23,8 +23,12 @@
 import org.apache.seatunnel.engine.server.serializable.CheckpointDataSerializerHook;
 import org.apache.seatunnel.engine.server.task.operation.TaskOperation;
 
+import com.hazelcast.nio.ObjectDataInput;
+import com.hazelcast.nio.ObjectDataOutput;
 import lombok.NoArgsConstructor;
 
+import java.io.IOException;
+
 @NoArgsConstructor
 public class CheckpointErrorReportOperation extends TaskOperation {
 
@@ -44,6 +48,18 @@ public void run() throws Exception {
                 .reportCheckpointErrorFromTask(taskLocation, errorMsg);
     }
 
+    @Override
+    protected void writeInternal(ObjectDataOutput out) throws IOException {
+        super.writeInternal(out);
+        out.writeString(errorMsg);
+    }
+
+    @Override
+    protected void readInternal(ObjectDataInput in) throws IOException {
+        super.readInternal(in);
+        errorMsg = in.readString();
+    }
+
     @Override
     public int getFactoryId() {
         return CheckpointDataSerializerHook.FACTORY_ID;