(inlong) branch master updated: [INLONG-11984][Manager] Fix the problem of Hive table creation statement error (#11985)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 0f52caeaf6 [INLONG-11984][Manager] Fix the problem of Hive table 
creation statement error (#11985)
0f52caeaf6 is described below

commit 0f52caeaf67f4544c11c0e829291f93e195c92ab
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Sep 5 10:25:42 2025 +0800

    [INLONG-11984][Manager] Fix the problem of Hive table creation statement 
error (#11985)
---
 .../inlong/manager/service/resource/sink/hive/SqlBuilder.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hive/SqlBuilder.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hive/SqlBuilder.java
index 4f32e6e435..1c20c0a789 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hive/SqlBuilder.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hive/SqlBuilder.java
@@ -50,7 +50,7 @@ public class SqlBuilder {
     public static String buildCreateTableSql(HiveTableInfo table) {
         StringBuilder sql = new StringBuilder();
         // Support _ beginning with underscore
-        String dbTableName = "`" + table.getDbName() + "." + 
table.getTableName() + "`";
+        String dbTableName = "`" + table.getDbName() + "`.`" + 
table.getTableName() + "`";
         sql.append("CREATE TABLE ").append(dbTableName);
 
         // Construct columns and partition columns
@@ -68,7 +68,7 @@ public class SqlBuilder {
      */
     public static String buildDescTableSql(String dbName, String tableName) {
         StringBuilder sql = new StringBuilder();
-        String fullTableName = "`" + dbName + "." + tableName + "`";
+        String fullTableName = "`" + dbName + "`.`" + tableName + "`";
         sql.append("DESC ").append(fullTableName);
 
         LOGGER.info("desc table sql={}", sql);
@@ -81,7 +81,7 @@ public class SqlBuilder {
     public static String buildAddColumnSql(String dbName, String tableName, 
List<HiveColumnInfo> columnList) {
         StringBuilder sql = new StringBuilder();
         // Support _ beginning with underscore
-        String dbTableName = "`" + dbName + "." + tableName + "`";
+        String dbTableName = "`" + dbName + "`.`" + tableName + "`";
         sql.append("ALTER TABLE ").append(dbTableName);
 
         // add columns