You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2015/02/04 19:41:43 UTC

svn commit: r1657368 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java

Author: cheolsoo
Date: Wed Feb  4 18:41:43 2015
New Revision: 1657368

URL: http://svn.apache.org/r1657368
Log:
PIG-4409: fs.defaultFS is overwritten in JobConf by replicated join at runtime (cheolsoo)

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1657368&r1=1657367&r2=1657368&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Feb  4 18:41:43 2015
@@ -136,6 +136,8 @@ IMPROVEMENTS
 
 BUG FIXES
 
+PIG-4409: fs.defaultFS is overwritten in JobConf by replicated join at runtime (cheolsoo)
+
 PIG-4404: LOAD with HBaseStorage on secure cluster is broken in Tez (rohini)
 
 PIG-4375: ObjectCache should use ProcessorContext.getObjectRegistry() (rohini)

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java?rev=1657368&r1=1657367&r2=1657368&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/datastorage/ConfigurationUtil.java Wed Feb  4 18:41:43 2015
@@ -80,7 +80,7 @@ public class ConfigurationUtil {
             localConf.addResource("core-default.xml");
         } else {
             if (PigMapReduce.sJobContext!=null) {
-                localConf = PigMapReduce.sJobContext.getConfiguration();
+                localConf = new Configuration(PigMapReduce.sJobContext.getConfiguration());
             } else {
                 localConf = new Configuration(true);
             }