svn commit: r1424150 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/util/AddFilesWithMissingEntries.java

[ecn]

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