HIVE-28712: Fix error wrt maxParts in partition logs

apache · Feb 5, 2025 · b1caa67 · b1caa67
1 parent da272b4
commit b1caa67
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HMSHandler.java b/...metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HMSHandler.java
@@ -810,10 +810,10 @@ private void startPartitionFunction(String function, String catName, String db,
                     + maxParts);
   }
 
-  private void startPartitionFunction(String function, String catName, String db, String tbl, int maxParts,
+  private void startPartitionFunction(String function, String catName, String db, String tbl, int partitionlimit,
                                       String expression, String defaultPartitionName) {
     startFunction(function, " : tbl=" + TableName.getQualified(catName, db, tbl) + ": Expression=" + expression
-            + ": Default partition name=" + defaultPartitionName + ": Max partitions=" + maxParts);
+            + ": Default partition name=" + defaultPartitionName + ": Max partitions=" + partitionlimit);
   }
 
   private String getGroupsCountAndUsername(final String user_name, final List<String> group_names) {
@@ -7601,8 +7601,8 @@ public PartitionsByExprResult get_partitions_by_expr(
     String catName = req.isSetCatName() ? req.getCatName() : getDefaultCatalog(conf);
     String expr = req.isSetExpr() ? Arrays.toString((req.getExpr())) : "";
     String defaultPartitionName = req.isSetDefaultPartitionName() ? req.getDefaultPartitionName() : "";
-    int maxParts = req.getMaxParts();
-    startPartitionFunction("get_partitions_by_expr", catName, dbName, tblName, maxParts, expr, defaultPartitionName);
+    int partitionLimit = MetastoreConf.getIntVar(conf, MetastoreConf.ConfVars.LIMIT_PARTITION_REQUEST);
+    startPartitionFunction("get_partitions_by_expr", catName, dbName, tblName, partitionLimit, expr, defaultPartitionName);
     fireReadTablePreEvent(catName, dbName, tblName);
     PartitionsByExprResult ret = null;
     Exception ex = null;