MAPREDUCE-7372 MapReduce set permission too late in copyJar method (#…

…4026). Contributed by Zhang Dongsheng. Reviewed-by: Steve Loughran <[email protected]> Signed-off-by: Chris Nauroth <[email protected]> (cherry picked from commit 9fe9623)
apache · Jul 25, 2022 · 1d2a60f · 1d2a60f
1 parent fffb0bd
commit 1d2a60f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java b/...-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java
@@ -783,9 +783,11 @@ private URI useSharedCache(URI sourceFile, String resourceName,
   void copyJar(Path originalJarPath, Path submitJarFile,
       short replication) throws IOException {
     jtFs.copyFromLocalFile(originalJarPath, submitJarFile);
-    jtFs.setReplication(submitJarFile, replication);
+    // The operation of setReplication requires certain permissions
+    // so we need to make sure it has enough permissions
     jtFs.setPermission(submitJarFile, new FsPermission(
         JobSubmissionFiles.JOB_FILE_PERMISSION));
+    jtFs.setReplication(submitJarFile, replication);
   }
 
   private void addLog4jToDistributedCache(Job job, Path jobSubmitDir)