diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java index d82973c..bf9d144 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java @@ -845,9 +845,6 @@ public static ReduceSinkDesc getReduceSinkDesc( partitionCols.addAll(keyCols); } else if (numPartitionFields >= 0) { partitionCols.addAll(keyCols.subList(0, numPartitionFields)); - } else { - // numPartitionFields = -1 means random partitioning - partitionCols.add(TypeCheckProcFactory.DefaultExprProcessor.getFuncExprNodeDesc("rand")); } StringBuilder order = new StringBuilder();