Index: ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFComputeStats.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFComputeStats.java (revision 1482697) +++ ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFComputeStats.java (working copy) @@ -26,7 +26,6 @@ import org.apache.hadoop.hive.ql.exec.UDFArgumentTypeException; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.ql.parse.SemanticException; -import org.apache.hadoop.hive.ql.util.JavaDataModel; import org.apache.hadoop.hive.serde2.io.DoubleWritable; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory; @@ -466,8 +465,8 @@ public void reset(AggregationBuffer agg) throws HiveException { LongStatsAgg myagg = (LongStatsAgg) agg; myagg.columnType = new String("Long"); - myagg.min = 0; - myagg.max = 0; + myagg.min = Long.MAX_VALUE; + myagg.max = Long.MIN_VALUE; myagg.countNulls = 0; myagg.firstItem = true; } @@ -786,8 +785,8 @@ public void reset(AggregationBuffer agg) throws HiveException { DoubleStatsAgg myagg = (DoubleStatsAgg) agg; myagg.columnType = new String("Double"); - myagg.min = 0.0; - myagg.max = 0.0; + myagg.min = Double.POSITIVE_INFINITY; + myagg.max = Double.NEGATIVE_INFINITY; myagg.countNulls = 0; myagg.firstItem = true; }