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,