diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java index ac451d4..15b0991 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java @@ -70,6 +70,7 @@ import org.apache.hadoop.hive.shims.ShimLoader; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.util.ReflectionUtils; +import org.apache.hadoop.util.Shell; /** * MapredLocalTask represents any local work (i.e.: client side work) that hive needs to @@ -244,6 +245,11 @@ public int execute(DriverContext driverContext) { for (Map.Entry entry : variables.entrySet()) { String name = entry.getKey(); String value = entry.getValue(); + if(value != null) { + if (Shell.WINDOWS) { + value = value.replaceAll("^\"|\"$", ""); + } + } env[pos++] = name + "=" + value; LOG.debug("Setting env: " + env[pos-1]); }