You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ma...@apache.org on 2013/01/28 07:28:17 UTC

svn commit: r1439273 - /hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java

Author: mattf
Date: Mon Jan 28 06:28:17 2013
New Revision: 1439273

URL: http://svn.apache.org/viewvc?rev=1439273&view=rev
Log:
finish submission for MAPREDUCE-4396.  Include unit test from HADOOP-8734.

Modified:
    hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java

Modified: hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java?rev=1439273&r1=1439272&r2=1439273&view=diff
==============================================================================
--- hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java (original)
+++ hadoop/common/branches/branch-1.1/src/test/org/apache/hadoop/filecache/TestMRWithDistributedCache.java Mon Jan 28 06:28:17 2013
@@ -33,6 +33,7 @@ import org.apache.commons.logging.LogFac
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FSDataOutputStream;
 import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.FileUtil;
 import org.apache.hadoop.fs.LocalFileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.LongWritable;
@@ -133,6 +134,10 @@ public class TestMRWithDistributedCache 
         makeJar(new Path(TEST_ROOT_DIR, "distributed.third.jar"), 3);
     Path fourth =
         makeJar(new Path(TEST_ROOT_DIR, "distributed.fourth.jar"), 4);
+    // Change permissions on one file to be private (others cannot read
+    // the file) to make sure private distributed cache works fine with
+    // the LocalJobRunner.
+    FileUtil.chmod(fourth.toUri().getPath(), "700");
 
     // Creates the Job Configuration
     DistributedCache.addCacheFile(