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

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


The following commit(s) were added to refs/heads/master by this push:
     new ff46f8812a8 HIVE-27667: Fix get partitions with max_parts (#4662). 
(Yuming Wang, reviewed by Ayush Saxena)
ff46f8812a8 is described below

commit ff46f8812a80cf086c92af943dd4f9aff96290b0
Author: Yuming Wang <yumw...@ebay.com>
AuthorDate: Tue Sep 5 15:32:01 2023 +0800

    HIVE-27667: Fix get partitions with max_parts (#4662). (Yuming Wang, 
reviewed by Ayush Saxena)
---
 ql/src/test/org/apache/hadoop/hive/ql/metadata/TestHive.java           | 3 +++
 .../src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java    | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/ql/src/test/org/apache/hadoop/hive/ql/metadata/TestHive.java 
b/ql/src/test/org/apache/hadoop/hive/ql/metadata/TestHive.java
index 897e2e20026..df3ecf6f662 100755
--- a/ql/src/test/org/apache/hadoop/hive/ql/metadata/TestHive.java
+++ b/ql/src/test/org/apache/hadoop/hive/ql/metadata/TestHive.java
@@ -838,6 +838,9 @@ public class TestHive {
       partialSpec.put("hr", "14");
       assertEquals(1, hm.getPartitions(tbl, partialSpec).size());
 
+      // Test get partitions with max_parts
+      assertEquals(1, hm.getPartitions(tbl, new HashMap(), (short) 1).size());
+
       hm.dropTable(Warehouse.DEFAULT_DATABASE_NAME, tableName);
     } catch (Throwable e) {
       System.err.println(StringUtils.stringifyException(e));
diff --git 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
index a3b679c0abd..15916e78983 100644
--- 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
+++ 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
@@ -3959,7 +3959,7 @@ public class ObjectStore implements RawStore, 
Configurable {
         LOG.info(
             "Redirecting to directSQL enabled API: db: {} tbl: {} partVals: 
{}",
             db_name, tbl_name, Joiner.on(',').join(part_vals));
-        return getPartitions(catName, db_name, tbl_name, -1);
+        return getPartitions(catName, db_name, tbl_name, max_parts);
       }
       LOG.debug("executing listPartitionNamesPsWithAuth");
       Collection parts = getPartitionPsQueryResults(catName, db_name, tbl_name,

Reply via email to