fix

dataroaring · Jun 20, 2024 · 152c44a · 152c44a
1 parent 57ba82f
commit 152c44a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 12 deletions.
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
@@ -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
@@ -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);