svn commit: r664097 - in /hadoop/core/trunk: CHANGES.txt src/java/org/apache/hadoop/filecache/DistributedCache.java

[ddas]

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);