fix

dataroaring · Jun 24, 2024 · b4c6685 · b4c6685
1 parent d30650b
commit b4c6685
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/journal/JournalEntity.java b/fe/fe-core/src/main/java/org/apache/doris/journal/JournalEntity.java
@@ -244,8 +244,7 @@ public void readFields(DataInput in) throws IOException {
                 break;
             }
             case OperationType.OP_ADD_PARTITION: {
-                data = new PartitionPersistInfo();
-                ((PartitionPersistInfo) data).readFields(in);
+                data = PartitionPersistInfo.read(in);
                 isRead = true;
                 break;
             }

diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/PartitionPersistInfo.java b/fe/fe-core/src/main/java/org/apache/doris/persist/PartitionPersistInfo.java
@@ -124,6 +124,16 @@ public void write(DataOutput out) throws IOException {
         Text.writeString(out, GsonUtils.GSON.toJson(this));
     }
 
+    public static PartitionPersistInfo read(DataInput in) throws IOException {
+        if (Env.getCurrentEnvJournalVersion() >= FeMetaVersion.VERSION_136) {
+            return GsonUtils.GSON.fromJson(Text.readString(in), PartitionPersistInfo.class);
+        } else {
+            PartitionPersistInfo info = new PartitionPersistInfo();
+            info.readFields(in);
+            return info;
+        }
+    }
+
     public void readFields(DataInput in) throws IOException {
         dbId = in.readLong();
         tableId = in.readLong();