svn commit: r1236425 - /incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java

[kt...@apache.org]

Author: kturner
Date: Thu Jan 26 22:47:58 2012
New Revision: 1236425

URL: http://svn.apache.org/viewvc?rev=1236425&view=rev
Log:
ACCUMULO-334 Made split recovery func test verify bulk flags were copied.

Modified:
    incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java

Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java?rev=1236425&r1=1236424&r2=1236425&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/test/functional/SplitRecoveryTest.java Thu Jan 26 22:47:58 2012
@@ -184,6 +184,17 @@ public class SplitRecoveryTest extends F
     
     ensureTabletHasNoUnexpectedMetadataEntries(low, lowDatafileSizes);
     ensureTabletHasNoUnexpectedMetadataEntries(high, highDatafileSizes);
+    
+    Map<String,Long> lowBulkFiles = MetadataTable.getBulkFilesLoaded(SecurityConstants.getSystemCredentials(), low);
+    Map<String,Long> highBulkFiles = MetadataTable.getBulkFilesLoaded(SecurityConstants.getSystemCredentials(), high);
+    
+    if (!lowBulkFiles.equals(highBulkFiles)) {
+      throw new Exception(" " + lowBulkFiles + " != " + highBulkFiles + " " + low + " " + high);
+    }
+    
+    if (lowBulkFiles.size() == 0) {
+      throw new Exception(" no bulk files " + low);
+    }
   }
   
   private void ensureTabletHasNoUnexpectedMetadataEntries(KeyExtent extent, SortedMap<String,DataFileValue> expectedMapFiles) throws Exception {