This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new f92c0acba0a [Bug] When using the hive catalog the hive table name is
uppercase, the Doris query is reported wrong #29058 (#29059)
f92c0acba0a is described below
commit f92c0acba0a4fcfd87e87b0e945c1ed3083e933d
Author: Guangming Lu <[email protected]>
AuthorDate: Sun Dec 31 13:48:08 2023 +0800
[Bug] When using the hive catalog the hive table name is uppercase, the
Doris query is reported wrong #29058 (#29059)
---
.../java/org/apache/doris/datasource/hive/event/AlterTableEvent.java | 3 ++-
.../java/org/apache/doris/datasource/hive/event/CreateTableEvent.java | 3 ++-
.../java/org/apache/doris/datasource/hive/event/MetastoreEvent.java | 4 ++--
3 files changed, 6 insertions(+), 4 deletions(-)
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 706f8cd303d..6de71fbbc59 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
org.apache.hadoop.hive.metastore.messaging.json.JSONAlterTableMessage;
import java.security.SecureRandom;
import java.util.List;
+import java.util.Locale;
/**
* MetastoreEvent for ALTER_TABLE event type
@@ -65,6 +65,7 @@ public class AlterTableEvent extends MetastoreTableEvent {
(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 3dff6420a8a..4c3615fbda8 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.api.Table;
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 @@ public class CreateTableEvent extends MetastoreTableEvent {
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 9dd4e79741e..f9771562ed4 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.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
+import java.util.Locale;
import java.util.Map;
/**
@@ -77,7 +77,7 @@ public abstract class MetastoreEvent {
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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
