From 3724f0eb9bdb57f6b98ba492abb5b95368eceaa2 Mon Sep 17 00:00:00 2001
From: yuzelin <zelin.yzl@alibaba-inc.com>
Date: Fri, 2 Aug 2024 11:00:05 +0800
Subject: [PATCH] [hotfix] HiveMetastoreClient should ignore branch

---
 .../org/apache/paimon/hive/HiveMetastoreClient.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java
index 0192e0022fb0..b006f09c99a4 100644
--- a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java
+++ b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java
@@ -69,7 +69,7 @@ public class HiveMetastoreClient implements MetastoreClient {
                                 client ->
                                         client.getTable(
                                                 identifier.getDatabaseName(),
-                                                identifier.getObjectName()))
+                                                identifier.getTableName()))
                         .getSd();
     }
 
@@ -86,7 +86,7 @@ public void addPartition(LinkedHashMap<String, String> partitionSpec) throws Exc
                     client ->
                             client.getPartition(
                                     identifier.getDatabaseName(),
-                                    identifier.getObjectName(),
+                                    identifier.getTableName(),
                                     partitionValues));
             // do nothing if the partition already exists
         } catch (NoSuchObjectException e) {
@@ -99,7 +99,7 @@ public void addPartition(LinkedHashMap<String, String> partitionSpec) throws Exc
 
             Partition hivePartition = new Partition();
             hivePartition.setDbName(identifier.getDatabaseName());
-            hivePartition.setTableName(identifier.getObjectName());
+            hivePartition.setTableName(identifier.getTableName());
             hivePartition.setValues(partitionValues);
             hivePartition.setSd(newSd);
             int currentTime = (int) (System.currentTimeMillis() / 1000);
@@ -118,7 +118,7 @@ public void deletePartition(LinkedHashMap<String, String> partitionSpec) throws
                     client ->
                             client.dropPartition(
                                     identifier.getDatabaseName(),
-                                    identifier.getObjectName(),
+                                    identifier.getTableName(),
                                     partitionValues,
                                     false));
         } catch (NoSuchObjectException e) {
@@ -133,7 +133,7 @@ public void markDone(LinkedHashMap<String, String> partitionSpec) throws Excepti
                     client ->
                             client.markPartitionForEvent(
                                     identifier.getDatabaseName(),
-                                    identifier.getObjectName(),
+                                    identifier.getTableName(),
                                     partitionSpec,
                                     PartitionEventType.LOAD_DONE));
         } catch (NoSuchObjectException e) {