diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java index eb4e77a..1b8e7d2 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java @@ -568,6 +568,7 @@ protected void closeOp(boolean abort) throws HiveException { } super.closeOp(abort); out = null; + random = null; if (isLogInfoEnabled) { LOG.info(toString() + ": records written - " + numRows); }