diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/AlterTableEvent.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/AlterTableEvent.java index 706f8cd303de955..6de71fbbc592a0e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/AlterTableEvent.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/AlterTableEvent.java @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - package org.apache.doris.datasource.hive.event; import org.apache.doris.catalog.Env; @@ -29,6 +28,7 @@ import java.security.SecureRandom; import java.util.List; +import java.util.Locale; /** * MetastoreEvent for ALTER_TABLE event type @@ -65,6 +65,7 @@ private AlterTableEvent(NotificationEvent event, String catalogName) { (JSONAlterTableMessage) MetastoreEventsProcessor.getMessageDeserializer(event.getMessageFormat()) .getAlterTableMessage(event.getMessage()); tableAfter = Preconditions.checkNotNull(alterTableMessage.getTableObjAfter()); + tableAfter.setTableName(tableAfter.getTableName().toLowerCase(Locale.ROOT)); tableBefore = Preconditions.checkNotNull(alterTableMessage.getTableObjBefore()); tblNameAfter = tableAfter.getTableName(); } catch (Exception e) { diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/CreateTableEvent.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/CreateTableEvent.java index 3dff6420a8a6656..4c3615fbda8915e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/CreateTableEvent.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/CreateTableEvent.java @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - package org.apache.doris.datasource.hive.event; import org.apache.doris.catalog.Env; @@ -28,6 +27,7 @@ import org.apache.hadoop.hive.metastore.messaging.CreateTableMessage; import java.util.List; +import java.util.Locale; /** * MetastoreEvent for CREATE_TABLE event type @@ -51,6 +51,7 @@ private CreateTableEvent(NotificationEvent event, String catalogName) throws Met MetastoreEventsProcessor.getMessageDeserializer(event.getMessageFormat()) .getCreateTableMessage(event.getMessage()); hmsTbl = Preconditions.checkNotNull(createTableMessage.getTableObj()); + hmsTbl.setTableName(hmsTbl.getTableName().toLowerCase(Locale.ROOT)); } catch (Exception e) { throw new MetastoreNotificationException( debugString("Unable to deserialize the event message"), e); 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 9dd4e79741ef2de..f9771562ed4bb21 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 @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - package org.apache.doris.datasource.hive.event; import org.apache.doris.datasource.hive.HMSCachedClient; @@ -25,6 +24,7 @@ import org.apache.logging.log4j.Logger; import java.util.List; +import java.util.Locale; import java.util.Map; /** @@ -77,7 +77,7 @@ protected MetastoreEvent(long eventId, String catalogName, String dbName, protected MetastoreEvent(NotificationEvent event, String catalogName) { this.event = event; - this.dbName = event.getDbName(); + this.dbName = event.getDbName().toLowerCase(Locale.ROOT); this.tblName = event.getTableName(); this.eventId = event.getEventId(); this.eventTime = event.getEventTime() * 1000L;