diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java index 086ccb2..d35e3ba 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java @@ -797,10 +797,11 @@ private JSONObject outputPlan(Object work, PrintStream out, operator.getOperatorId()); if (!this.work.isUserLevelExplain() && this.work.isFormatted() && operator instanceof ReduceSinkOperator) { - ((JSONObject) jsonOut.get(JSONObject.getNames(jsonOut)[0])).put( - OUTPUT_OPERATORS, - Arrays.toString(((ReduceSinkOperator) operator).getConf().getOutputOperators() - .toArray())); + List outputOperators = ((ReduceSinkOperator) operator).getConf().getOutputOperators(); + if (outputOperators != null) { + ((JSONObject) jsonOut.get(JSONObject.getNames(jsonOut)[0])).put(OUTPUT_OPERATORS, + Arrays.toString(outputOperators.toArray())); + } } } }