diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMkCollectionEvaluator.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMkCollectionEvaluator.java index 2b5e6dd..afee1cc 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMkCollectionEvaluator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMkCollectionEvaluator.java @@ -115,10 +115,8 @@ public void iterate(AggregationBuffer agg, Object[] parameters) assert (parameters.length == 1); Object p = parameters[0]; - if (p != null) { - MkArrayAggregationBuffer myagg = (MkArrayAggregationBuffer) agg; - putIntoCollection(p, myagg); - } + MkArrayAggregationBuffer myagg = (MkArrayAggregationBuffer) agg; + putIntoCollection(p, myagg); } //mapside