You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by st...@apache.org on 2022/01/21 05:50:32 UTC
[impala] 01/02: IMPALA-11075: Use latest API for get_partitions_ps_with_auth()
This is an automated email from the ASF dual-hosted git repository.
stigahuang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
commit 402c12b5d3394df4381bfe1604c28272dd247581
Author: Steve Carlin <sc...@cloudera.com>
AuthorDate: Tue Jan 18 19:09:45 2022 -0800
IMPALA-11075: Use latest API for get_partitions_ps_with_auth()
Change the code to use the latest API for get_partitions_ps_with_auth().
Change-Id: I3e93d97f97b3a4f6dd36a40476f55f430f74d6ce
Reviewed-on: http://gerrit.cloudera.org:8080/18157
Reviewed-by: Vihang Karajgaonkar <vi...@cloudera.com>
Tested-by: Impala Public Jenkins <im...@cloudera.com>
---
.../apache/impala/catalog/metastore/MetastoreServiceHandler.java | 9 +--------
1 file changed, 1 insertion(+), 8 deletions(-)
diff --git a/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java b/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java
index 48e6c3c..0b624c7 100644
--- a/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java
+++ b/fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java
@@ -1415,14 +1415,7 @@ public abstract class MetastoreServiceHandler extends AbstractThriftHiveMetastor
GetPartitionsPsWithAuthRequest req)
throws MetaException, NoSuchObjectException, TException {
try (MetaStoreClient client = catalog_.getMetaStoreClient()) {
- List<Partition> partitions = client.getHiveClient().getThriftClient()
- .get_partitions_ps_with_auth(MetaStoreUtils
- .prependCatalogToDbName(req.getCatName(), req.getDbName(), serverConf_),
- req.getTblName(), req.getPartVals(), req.getMaxParts(),
- req.getUserName(), req.getGroupNames());
- GetPartitionsPsWithAuthResponse res = new GetPartitionsPsWithAuthResponse();
- res.setPartitions(partitions);
- return res;
+ return client.getHiveClient().getThriftClient().get_partitions_ps_with_auth_req(req);
}
}