ActiveDeletedBlobCollectionIT.simpleAsyncIndexUpdateBasedBlobCollection failing intermittently
@@ -24,6 +24,7 @@ import org.apache.jackrabbit.oak.Oak;
import org.apache.jackrabbit.oak.api.ContentRepository;
import org.apache.jackrabbit.oak.plugins.blob.datastore.DataStoreBlobStore;
import org.apache.jackrabbit.oak.plugins.document.DocumentMK;
+import org.apache.jackrabbit.oak.plugins.document.DocumentNodeStore;
import org.apache.jackrabbit.oak.plugins.document.MongoConnectionFactory;
import org.apache.jackrabbit.oak.plugins.document.MongoUtils;
import org.apache.jackrabbit.oak.plugins.document.mongo.MongoBlobStore;
@@ -39,6 +40,7 @@ import org.apache.jackrabbit.oak.spi.commit.Observer;
import org.apache.jackrabbit.oak.spi.mount.Mounts;
import org.apache.jackrabbit.oak.spi.query.QueryIndexProvider;
import org.apache.jackrabbit.oak.spi.security.OpenSecurityProvider;
+import org.junit.After;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Rule;
@@ -125,6 +127,13 @@ public class ActiveDeletedBlobCollectionIT extends AbstractActiveDeletedBlobTest
.createContentRepository();
}
+ @After
+ public void dispose() {
+ String dbName = mongoConnection.getDBName();
+ ((DocumentNodeStore) nodeStore).dispose();
+ MongoUtils.dropCollections(dbName);
+ }
+
@Test
public void simpleAsyncIndexUpdateBasedBlobCollection() throws Exception {
createIndex("test1", of("propa"));
