This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 3fb81139f4b [Fix][Bug] When using the hive catalog the hive table name
is uppercase, the Doris query is reported wrong #30166 (#30167)
3fb81139f4b is described below
commit 3fb81139f4b71e16d1f210c1f527b0a0ad9fcdc2
Author: Guangming Lu <[email protected]>
AuthorDate: Tue Jan 23 17:07:07 2024 +0800
[Fix][Bug] When using the hive catalog the hive table name is uppercase,
the Doris query is reported wrong #30166 (#30167)
---
.../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 8e70949a2b0..706cdc46172 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;
@@ -28,6 +27,7 @@ import org.apache.hadoop.hive.metastore.api.Table;
import org.apache.hadoop.hive.metastore.messaging.json.JSONAlterTableMessage;
import java.util.List;
+import java.util.Locale;
import java.util.Random;
/**
@@ -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 0a6e830316a..29d6a312ea1 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.hadoop.hive.metastore.api.NotificationEvent;
@@ -23,6 +22,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;
/**
@@ -75,7 +75,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]
