From 95a69a16d6f53605e2ef49c98efd6a95e3a09b60 Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Wed, 31 Jul 2024 15:28:10 +0800 Subject: [PATCH] [fix](catalog)fix db name may be null in NotificationEvent (#38421) cause by: #29059 --- .../apache/doris/datasource/hive/event/MetastoreEvent.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEvent.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEvent.java index 67348494befd48..04b0ccab799b81 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEvent.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEvent.java @@ -21,6 +21,7 @@ import org.apache.doris.datasource.hive.HMSCachedClient; import com.google.common.collect.ImmutableList; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hive.metastore.api.NotificationEvent; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; @@ -79,7 +80,9 @@ protected MetastoreEvent(long eventId, String catalogName, String dbName, protected MetastoreEvent(NotificationEvent event, String catalogName) { this.event = event; - this.dbName = event.getDbName().toLowerCase(Locale.ROOT); + // Some events that we don't care about, dbName may be empty + String eventDbName = event.getDbName(); + this.dbName = StringUtils.isEmpty(eventDbName) ? eventDbName : eventDbName.toLowerCase(Locale.ROOT); this.tblName = event.getTableName(); this.eventId = event.getEventId(); this.eventTime = event.getEventTime() * 1000L;