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(