diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java index e7fe4a2..7ff8ddc 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java @@ -27,7 +27,9 @@ import java.util.ArrayList; import java.util.Collection; import java.util.Collections; +import java.util.Iterator; import java.util.List; +import java.util.Map; import java.util.Properties; import org.apache.commons.lang.StringUtils; @@ -173,6 +175,12 @@ public void initialize(QueryState queryState, QueryPlan queryPlan, DriverContext CompilationOpContext opContext) { super.initialize(queryState, queryPlan, driverContext, opContext); + Iterator> iter = conf.iterator(); + while(iter.hasNext()) { + String key = iter.next().getKey(); + conf.set(key, conf.get(key)); + } + job = new JobConf(conf, ExecDriver.class); initializeFiles("tmpjars", getResource(conf, SessionState.ResourceType.JAR));