You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2015/05/22 00:37:22 UTC
svn commit: r1680962 -
/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
Author: daijy
Date: Thu May 21 22:37:22 2015
New Revision: 1680962
URL: http://svn.apache.org/r1680962
Log:
PIG-4556: Local mode is broken in some case by PIG-4247 (PIG-4556-3.patch)
Modified:
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java?rev=1680962&r1=1680961&r2=1680962&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java Thu May 21 22:37:22 2015
@@ -189,10 +189,9 @@ public abstract class HExecutionEngine i
// existing properties All of the above is accomplished in the method
// call below
- JobConf jc = getS3Conf();
+ JobConf jc;
if (!this.pigContext.getExecType().isLocal()) {
- JobConf execConf = getExecConf(properties);
- ConfigurationUtil.mergeConf(jc, execConf);
+ jc = getExecConf(properties);
// Trick to invoke static initializer of DistributedFileSystem to
// add hdfs-default.xml into configuration
@@ -206,8 +205,9 @@ public abstract class HExecutionEngine i
properties.setProperty(FILE_SYSTEM_LOCATION, "file:///");
properties.setProperty(ALTERNATIVE_FILE_SYSTEM_LOCATION, "file:///");
- JobConf localConf = getLocalConf();
- ConfigurationUtil.mergeConf(jc, localConf);
+ jc = getLocalConf();
+ JobConf s3Jc = getS3Conf();
+ ConfigurationUtil.mergeConf(jc, s3Jc);
}
// the method below alters the properties object by overriding the