diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/AbstractJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/AbstractJob.java
index c4dc4e459642b6c..85162b281f3c953 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/backup/AbstractJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/backup/AbstractJob.java
@@ -189,17 +189,6 @@ public static AbstractJob read(DataInput in) throws IOException {
 
     @Override
     public void write(DataOutput out) throws IOException {
-        if (taskErrMsg != null) {
-            Map<Long, String> newMsg = Maps.newHashMap();
-            taskErrMsg.entrySet().stream().limit(3)
-                .forEach(e -> newMsg.put(e.getKey(), e.getValue()));
-            taskErrMsg = newMsg;
-        }
-        Text.writeString(out, GsonUtils.GSON.toJson(this));
-    }
-
-    // for restore job
-    public void writeFields(DataOutput out) throws IOException {
         // ATTN: must write type first
         Text.writeString(out, type.name());
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java
index fab1a0f9cfe1192..903e2ef95efe80e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java
@@ -2099,7 +2099,7 @@ private void setTableStateToNormal(Database db, boolean committed, boolean isRep
 
     @Override
     public void write(DataOutput out) throws IOException {
-        super.writeFields(out);
+        super.write(out);
 
         Text.writeString(out, backupTimestamp);
         jobInfo.write(out);