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 2016/03/26 06:51:19 UTC

svn commit: r1736679 - /pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java

Author: cheolsoo
Date: Sat Mar 26 05:51:19 2016
New Revision: 1736679

URL: http://svn.apache.org/viewvc?rev=1736679&view=rev
Log:
PIG-4850: Registered jars do not use submit replication

Modified:
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java?rev=1736679&r1=1736678&r2=1736679&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java Sat Mar 26 05:51:19 2016
@@ -1783,6 +1783,7 @@ public class JobControlCompiler{
             PigContext pigContext,
             Configuration conf,
             URL url) throws IOException {
+        short replication = (short) conf.getInt(MRConfiguration.SUMIT_REPLICATION, 3);
 
         boolean cacheEnabled =
                 conf.getBoolean(PigConfiguration.PIG_USER_CACHE_ENABLED, false);
@@ -1809,6 +1810,7 @@ public class JobControlCompiler{
                 os.close();
             }
         }
+        fs.setReplication(dst, replication);
         return dst;
     }