diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java index dd8e7fa1e3..e1b582a540 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/ExternalDatabase.java @@ -332,12 +332,13 @@ public abstract class ExternalDatabase throw new NotImplementedException("dropTable() is not implemented"); } - public void createTable(String tableName, long tableId) { - throw new NotImplementedException("createTable() is not implemented"); - } - @Override public CatalogIf getCatalog() { return extCatalog; } + + // Only used for sync hive metastore event + public void replayCreateTableFromEvent(String tableName, long tableId) { + throw new NotImplementedException("createTable() is not implemented"); + } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/HMSExternalDatabase.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/HMSExternalDatabase.java index d53c934052..093ebe8b40 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/HMSExternalDatabase.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/HMSExternalDatabase.java @@ -74,9 +74,8 @@ public class HMSExternalDatabase extends ExternalDatabase { } @Override - public void createTable(String tableName, long tableId) { + public void replayCreateTableFromEvent(String tableName, long tableId) { LOG.debug("create table [{}]", tableName); - makeSureInitialized(); tableNameToId.put(tableName, tableId); HMSExternalTable table = getExternalTable(tableName, tableId, extCatalog); idToTbl.put(tableId, table); diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/IcebergExternalDatabase.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/IcebergExternalDatabase.java index 3e8a7beef9..8653c3e2dd 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/external/IcebergExternalDatabase.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/external/IcebergExternalDatabase.java @@ -60,9 +60,8 @@ public class IcebergExternalDatabase extends ExternalDatabase