diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java index 62aa574..6d06e9e 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java @@ -354,9 +354,11 @@ public void setChildren(Configuration hconf) throws Exception { StructObjectInspector tableRowOI = convertedOI.get(partDesc.getTableDesc()); contexts.put(op, initObjectInspector(hconf, context, tableRowOI)); - op.setParentOperators(new ArrayList>(1)); - op.getParentOperators().add(this); - children.add(op); + if (children.contains(op) == false) { + op.setParentOperators(new ArrayList>(1)); + op.getParentOperators().add(this); + children.add(op); + } } } @@ -378,8 +380,8 @@ private void initOperatorContext(List> children 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()); } } }