From 4981e1acb4d460a443c7ea328457d4e30b4f72a3 Mon Sep 17 00:00:00 2001 From: wangxiangyu Date: Sat, 2 Dec 2023 17:08:45 +0800 Subject: [PATCH] [Enhancement](multi-catalog) Speed up consume rate of hms event. --- .../main/java/org/apache/doris/datasource/CatalogMgr.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java index 7828efcfb73bb3..a7fe7020b00c78 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java @@ -824,7 +824,11 @@ public void createExternalTableFromEvent(String dbName, String tableName, db.writeLock(); try { ((HMSExternalDatabase) db).createTable(tableName, tblId); - ((HMSExternalDatabase) db).setLastUpdateTime(updateTime); + ((HMSExternalDatabase) db).setLastUpdateTime(System.currentTimeMillis()); + table = db.getTableNullable(tableName); + if (table != null) { + ((HMSExternalTable) table).setEventUpdateTime(updateTime); + } } finally { db.writeUnlock(); }