(doris) branch branch-3.0 updated: branch-3.0: [chore](binlog) Save table type in CreateTableRecord #44735 (#44835)

[dataroaring]

This is an automated email from the ASF dual-hosted git repository.

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 06d9a44559d branch-3.0: [chore](binlog) Save table type in 
CreateTableRecord #44735 (#44835)
06d9a44559d is described below

commit 06d9a44559d5d2457f7741010404de16ca793dc6
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 3 10:02:37 2024 +0800

    branch-3.0: [chore](binlog) Save table type in CreateTableRecord #44735 
(#44835)
    
    Cherry-picked from #44735
    
    Co-authored-by: walter <maoch...@selectdb.com>
---
 .../src/main/java/org/apache/doris/binlog/CreateTableRecord.java     | 5 +++++
 1 file changed, 5 insertions(+)

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
index 89d11fc014e..602afe88081 100644
--- 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 @@ package org.apache.doris.binlog;
 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 class CreateTableRecord {
         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);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org