[chore](binlog) Save table type in CreateTableRecord

apache · Nov 28, 2024 · 8a0188f · 8a0188f
1 parent d77bfa0
commit 8a0188f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/CreateTableRecord.java b/fe/fe-core/src/main/java/org/apache/doris/binlog/CreateTableRecord.java
@@ -20,6 +20,7 @@
 import org.apache.doris.catalog.Database;
 import org.apache.doris.catalog.Env;
 import org.apache.doris.catalog.Table;
+import org.apache.doris.catalog.TableIf.TableType;
 import org.apache.doris.persist.CreateTableInfo;
 import org.apache.doris.persist.gson.GsonUtils;
 
@@ -43,6 +44,8 @@ public class CreateTableRecord {
     private long tableId;
     @SerializedName(value = "tableName")
     private String tableName;
+    @SerializedName(value = "tableType")
+    protected TableType type;
     @SerializedName(value = "sql")
     private String sql;
 
@@ -56,6 +59,8 @@ public CreateTableRecord(long commitSeq, CreateTableInfo info) {
         String dbName = info.getDbName();
         this.dbName = dbName;
 
+        this.type = table.getType();
+
         Database db = Env.getCurrentInternalCatalog().getDbNullable(dbName);
         if (db == null) {
             LOG.warn("db not found. dbId: {}", dbId);