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

[cheolsoo]

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;
     }