Author: gunther
Date: Thu Dec 12 00:16:47 2013
New Revision: 1550325
URL: http://svn.apache.org/r1550325
Log:
HIVE-6011: correlation optimizer unit tests are failing on tez (Ashutosh
Chauhan via Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java
URL:
http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java?rev=1550325&r1=1550324&r2=1550325&view=diff
==============================================================================
---
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java
(original)
+++
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MuxOperator.java
Thu Dec 12 00:16:47 2013
@@ -215,7 +215,7 @@ public class MuxOperator extends Operato
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());
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java
URL:
http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java?rev=1550325&r1=1550324&r2=1550325&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java
(original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java
Thu Dec 12 00:16:47 2013
@@ -525,7 +525,7 @@ public abstract class Operator<T extends
}
public void processGroup(int tag) throws HiveException {
- if (childOperators == null) {
+ if (childOperators == null || childOperators.isEmpty()) {
return;
}
for (int i = 0; i < childOperatorsArray.length; i++) {
