You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@accumulo.apache.org by ec...@apache.org on 2012/12/20 20:12:53 UTC

svn commit: r1424644 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java

Author: ecn
Date: Thu Dec 20 19:12:53 2012
New Revision: 1424644

URL: http://svn.apache.org/viewvc?rev=1424644&view=rev
Log:
ACCUMULO-899 add the missing slash for borrowed files

Modified:
    accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java

Modified: accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java?rev=1424644&r1=1424643&r2=1424644&view=diff
==============================================================================
--- accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java (original)
+++ accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java Thu Dec 20 19:12:53 2012
@@ -65,7 +65,10 @@ public class RemoveEntriesForMissingFile
       count++;
       Key key = entry.getKey();
       String table = new String(KeyExtent.tableOfMetadataRow(entry.getKey().getRow()));
-      Path map = new Path(ServerConstants.getTablesDir() + "/" + table + key.getColumnQualifier().toString());
+      String file = key.getColumnQualifier().toString();
+      if (!file.startsWith("/"))
+        file = "/" + file;
+      Path map = new Path(ServerConstants.getTablesDir() + "/" + table + file);
       if (!fs.exists(map)) {
         missing++;
         log.info("File " + map + " is missing");