This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new ecfcca06cec [enhancement](binlog) Add dbName && tableName in
CreateTableRecord (#26901) (#27208)
ecfcca06cec is described below
commit ecfcca06cecbab3e560c74360de3b1d9e600fd70
Author: Jack Drogon <[email protected]>
AuthorDate: Fri Nov 17 21:21:57 2023 +0800
[enhancement](binlog) Add dbName && tableName in CreateTableRecord
(#26901) (#27208)
---
.../src/main/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 145b45396f7..89d11fc014e 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
