hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r664097 - in /hadoop/core/trunk: CHANGES.txt src/java/org/apache/hadoop/filecache/DistributedCache.java
Date Fri, 06 Jun 2008 19:33:46 GMT
Author: ddas
Date: Fri Jun  6 12:33:46 2008
New Revision: 664097

URL: http://svn.apache.org/viewvc?rev=664097&view=rev
Log:
HADOOP-3440. Fixes DistributedCache to not create symlinks for paths which  don't have fragments
even when createSymLink is true. Contributed by Abhijit Bagri.

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=664097&r1=664096&r2=664097&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Fri Jun  6 12:33:46 2008
@@ -504,6 +504,10 @@
     HADOOP-3503. Fix a race condition when client and namenode start simultaneous
     recovery of the same block.  (dhruba & Tsz Wo (Nicholas), SZE)
 
+    HADOOP-3440. Fixes DistributedCache to not create symlinks for paths which
+    don't have fragments even when createSymLink is true. 
+    (Abhijit Bagri via ddas) 
+
 Release 0.17.0 - 2008-05-18
 
   INCOMPATIBLE CHANGES

Modified: hadoop/core/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java?rev=664097&r1=664096&r2=664097&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java (original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java Fri Jun 
6 12:33:46 2008
@@ -297,6 +297,9 @@
                                     Path currentWorkDir) 
   throws IOException {
     boolean doSymlink = getSymlink(conf);
+    if(cache.getFragment() == null) {
+    	doSymlink = false;
+    }
     FileSystem fs = getFileSystem(cache, conf);
     String link = currentWorkDir.toString() + Path.SEPARATOR + cache.getFragment();
     File flink = new File(link);



Mime
View raw message