From aabb5d48843288df2b53729241086b757deb87f0 Mon Sep 17 00:00:00 2001 From: Jack Drogon Date: Mon, 13 Nov 2023 19:04:07 +0800 Subject: [PATCH] Add dbName && tableName in CreateTableRecord Signed-off-by: Jack Drogon --- .../java/org/apache/doris/binlog/CreateTableRecord.java | 9 ++++++++- 1 file changed, 8 insertions(+), 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 index 145b45396f71af..89d11fc014e979 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 @@ -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) {