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 3fd0379194f39d..1de756ce8038d4 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
@@ -1819,12 +1819,19 @@ public List
getTableObjectsByName(String dbName, List tableNames)
@Override
public List getTableObjectsByName(String catName, String dbName,
List tableNames) throws TException {
- GetTablesRequest req = new GetTablesRequest(dbName);
- req.setCatName(catName);
- req.setTblNames(tableNames);
- req.setCapabilities(version);
- List tabs = client.get_table_objects_by_name_req(req).getTables();
- return deepCopyTables(filterHook.filterTables(tabs));
+ List 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