diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/messaging/json/JSONAlterPartitionsMessage.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/messaging/json/JSONAlterPartitionsMessage.java index 41622c8c90bb..2ee38ea0dfef 100644 --- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/messaging/json/JSONAlterPartitionsMessage.java +++ b/standalone-metastore/metastore-server/src/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 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)); }