|
@@ -783,9 +783,11 @@ class JobResourceUploader {
|
|
|
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)
|