diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java index 1d1f967429..70035bb3b3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/stats/annotation/StatsRulesProcFactory.java @@ -2080,6 +2080,8 @@ public Object process(Node nd, Stack stack, NodeProcessorCtx procCtx, // Update largest relation if (rowCount > maxRowCount) { maxRowCount = rowCount; + } + if (dataSize > maxDataSize) { maxDataSize = dataSize; } }