address comments

dengzhhu653 · Dec 7, 2023 · 4651175 · 4651175
1 parent 325a646
commit 4651175
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...main/java/org/apache/hadoop/hive/metastore/messaging/json/JSONAlterPartitionsMessage.java b/...main/java/org/apache/hadoop/hive/metastore/messaging/json/JSONAlterPartitionsMessage.java
@@ -72,7 +72,11 @@ public JSONAlterPartitionsMessage(String server, String servicePrincipal, Table
       this.tableObjJson = MessageBuilder.createTableObjJson(tableObj);
       Iterator<Partition> iterator = partitionsAfter.iterator();
       while (iterator.hasNext()) {
-        Partition partitionObj = iterator.next();
+        Partition partitionObj = new Partition(iterator.next());
+        // remove stats from the partition to reduce the message size
+        if (partitionObj.isSetParameters()) {
+          partitionObj.getParameters().clear();
+        }
         partitions.add(MessageBuilder.getPartitionKeyValues(tableObj, partitionObj));
         partitionListJson.add(MessageBuilder.createPartitionObjJson(partitionObj));
       }