From 48b6d83dd535b5446c70d367e9f437bd4d47ee9a Mon Sep 17 00:00:00 2001
From: wangtao <emor93@foxmail.com>
Date: Sun, 18 Feb 2024 15:27:32 +0800
Subject: [PATCH] [fix](iceberg) iceberg hms support hive1 (#30985)

---
 .../hive/metastore/HiveMetaStoreClient.java   | 19 +++++++++++++------
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/fe/fe-core/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index 230d4b687a433d..8adad6d8bf307a 100644
--- a/fe/fe-core/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++ b/fe/fe-core/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -1815,12 +1815,19 @@ public List<Table> getTableObjectsByName(String dbName, List<String> tableNames)
   @Override
   public List<Table> getTableObjectsByName(String catName, String dbName,
                                            List<String> tableNames) throws TException {
-    GetTablesRequest req = new GetTablesRequest(dbName);
-    req.setCatName(catName);
-    req.setTblNames(tableNames);
-    req.setCapabilities(version);
-    List<Table> tabs = client.get_table_objects_by_name_req(req).getTables();
-    return deepCopyTables(filterHook.filterTables(tabs));
+      List<Table> tabs = new ArrayList<>();
+      if (hiveVersion == HiveVersion.V1_0 || hiveVersion == HiveVersion.V2_0) {
+          for (String tableName: tableNames) {
+              tabs.add(client.get_table(dbName, tableName));
+          }
+      } else {
+          GetTablesRequest req = new GetTablesRequest(dbName);
+          req.setCatName(catName);
+          req.setTblNames(tableNames);
+          req.setCapabilities(version);
+          tabs = client.get_table_objects_by_name_req(req).getTables();
+      }
+      return deepCopyTables(filterHook.filterTables(tabs));
   }
 
   @Override