diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java index 6870342..b10a7fa 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java @@ -215,7 +215,7 @@ protected void initializeOp(Configuration hconf) throws HiveException { protected void initializeChildren(Configuration hconf) throws HiveException { state = State.INIT; LOG.info("Operator " + id + " " + getName() + " initialized"); - if (childOperators == null) { + if (childOperators == null || childOperators.isEmpty()) { return; } LOG.info("Initializing children of " + id + " " + getName()); diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java index 90c4231..fadfea3 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java @@ -525,7 +525,7 @@ public void flush() throws HiveException { } public void processGroup(int tag) throws HiveException { - if (childOperators == null) { + if (childOperators == null || childOperators.isEmpty()) { return; } for (int i = 0; i < childOperatorsArray.length; i++) {