accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1424150 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java
Date Wed, 19 Dec 2012 21:39:13 GMT
Author: ecn
Date: Wed Dec 19 21:39:12 2012
New Revision: 1424150

URL: http://svn.apache.org/viewvc?rev=1424150&view=rev
Log:
ACCUMULO-709 do not add _tmp files to tables

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

Modified: accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java?rev=1424150&r1=1424149&r2=1424150&view=diff
==============================================================================
--- accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java
(original)
+++ accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java
Wed Dec 19 21:39:12 2012
@@ -113,6 +113,8 @@ public class AddFilesWithMissingEntries 
     log.info(row.toString());
     final Path path = new Path(ServerConstants.getTablesDir() + "/" + tableId + directory);
     for (FileStatus file : fs.listStatus(path)) {
+      if (file.getPath().getName().endsWith("_tmp") || file.getPath().getName().endsWith("_tmp.rf"))
+        continue;
       final String filename = directory + "/" + file.getPath().getName();
       if (!knownFiles.contains(filename)) {
         count++;



Mime
View raw message