[enhancement](binlog) Add dbName && tableName in CreateTableRecord (a…

…pache#26901) Signed-off-by: Jack Drogon <jack.xsuperman@gmail.com>
JackDrogon · Nov 17, 2023 · 105192b · 105192b
1 parent cd1ddd3
commit 105192b
Showing 1 changed file with 8 additions and 1 deletion.
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
@@ -37,17 +37,24 @@ public class CreateTableRecord {
     private long commitSeq;
     @SerializedName(value = "dbId")
     private long dbId;
+    @SerializedName(value = "dbName")
+    private String dbName;
     @SerializedName(value = "tableId")
     private long tableId;
+    @SerializedName(value = "tableName")
+    private String tableName;
     @SerializedName(value = "sql")
     private String sql;
 
     public CreateTableRecord(long commitSeq, CreateTableInfo info) {
+        this.commitSeq = commitSeq;
+
         Table table = info.getTable();
+        this.tableName = table.getName();
 
-        this.commitSeq = commitSeq;
         this.tableId = table.getId();
         String dbName = info.getDbName();
+        this.dbName = dbName;
 
         Database db = Env.getCurrentInternalCatalog().getDbNullable(dbName);
         if (db == null) {