[seatunnel] branch dev updated: [Hotfix][Zeta] Fix checkpoint error report without msg (#5137)

[tyrantlucifer]

This is an automated email from the ASF dual-hosted git repository.

tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 9dab2feb65 [Hotfix][Zeta] Fix checkpoint error report without msg 
(#5137)
9dab2feb65 is described below

commit 9dab2feb65661df107a8617c156c3ac078212d53
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Mon Jul 24 10:51:40 2023 +0800

    [Hotfix][Zeta] Fix checkpoint error report without msg (#5137)
---
 .../operation/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 75ec924b70..967e157231 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.execution.TaskLocation;
 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 class CheckpointErrorReportOperation extends 
TaskOperation {
                 .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;