Index: ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCollectSet.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCollectSet.java (revision 1338014) +++ ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCollectSet.java (working copy) @@ -156,8 +156,6 @@ } private void putIntoSet(Object p, MkArrayAggregationBuffer myagg) { - if (myagg.container.contains(p)) - return; Object pCopy = ObjectInspectorUtils.copyToStandardObject(p, this.inputOI); myagg.container.add(pCopy);