accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1424644 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/RemoveEntriesForMissingFiles.java
Date Thu, 20 Dec 2012 19:12:53 GMT
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");



Mime
View raw message