fix

dataroaring · Jun 21, 2024 · 06be42a · 06be42a
1 parent 6facaed
commit 06be42a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -3576,8 +3576,7 @@ public long loadDb(DataInputStream dis, long checksum) throws IOException, DdlEx
         int dbCount = dis.readInt();
         long newChecksum = checksum ^ dbCount;
         for (long i = 0; i < dbCount; ++i) {
-            Database db = new Database();
-            db.readFields(dis);
+            Database db = Database.read(dis);
             newChecksum ^= db.getId();
 
             Database dbPrev = fullNameToDb.get(db.getFullName());

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/InsertLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/InsertLoadJob.java
@@ -115,7 +115,8 @@ public Set<String> getTableNames() throws MetaNotFoundException {
         return Sets.newHashSet(table.getName());
     }
 
-    public void readFields(DataInput in) throws IOException {
+    @Override
+    protected void readFields(DataInput in) throws IOException {
         super.readFields(in);
         tableId = in.readLong();
     }

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java
@@ -1034,7 +1034,7 @@ public void write(DataOutput out) throws IOException {
         Text.writeString(out, GsonUtils.GSON.toJson(this));
     }
 
-    public void readFields(DataInput in) throws IOException {
+    protected void readFields(DataInput in) throws IOException {
 
         if (!isJobTypeRead) {
             jobType = EtlJobType.valueOf(Text.readString(in));