You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2014/10/29 21:59:07 UTC
svn commit: r1635299 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
Author: gunther
Date: Wed Oct 29 20:59:07 2014
New Revision: 1635299
URL: http://svn.apache.org/r1635299
Log:
HIVE-8647: HIVE-8186 causes addition of same child operator multiple times (Vikram Dixit K via Gunther Hagleitner)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java?rev=1635299&r1=1635298&r2=1635299&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java Wed Oct 29 20:59:07 2014
@@ -354,9 +354,11 @@ public class MapOperator extends Operato
StructObjectInspector tableRowOI = convertedOI.get(partDesc.getTableDesc());
contexts.put(op, initObjectInspector(hconf, context, tableRowOI));
- op.setParentOperators(new ArrayList<Operator<? extends OperatorDesc>>(1));
- op.getParentOperators().add(this);
- children.add(op);
+ if (children.contains(op) == false) {
+ op.setParentOperators(new ArrayList<Operator<? extends OperatorDesc>>(1));
+ op.getParentOperators().add(this);
+ children.add(op);
+ }
}
}
@@ -378,8 +380,8 @@ public class MapOperator extends Operato
if (prev != null && !prev.equals(context.rowObjectInspector)) {
throw new HiveException("Conflict on row inspector for " + context.alias);
}
- if (isLogInfoEnabled) {
- LOG.info("dump " + context.op + " " + context.rowObjectInspector.getTypeName());
+ if (isLogDebugEnabled) {
+ LOG.debug("dump " + context.op + " " + context.rowObjectInspector.getTypeName());
}
}
}