more pauses

stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java

@@ -353,10 +353,10 @@ public void deleteApplication(UUID applicationId) throws Exception {
                     }
                 });
 
-                final Observable nodes = managementGraphManager.deleteNode(deletedAppId, Long.MAX_VALUE);
-                final Observable deleteIndex = aei.deleteApplication();
+                final Observable deleteNodeGraph = managementGraphManager.deleteNode(deletedAppId, Long.MAX_VALUE);
+                final Observable deleteAppFromIndex = aei.deleteApplication();
 
-                return Observable.concat(copyConnections, nodes, deleteIndex)
+                return Observable.concat(copyConnections, deleteNodeGraph, deleteAppFromIndex)
                     .doOnCompleted(() -> {
                     try {
                         managementEm.delete(appInfoToDelete);

stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java

@@ -291,14 +291,13 @@ public void singleOrderByMaxLimit( IoHelper io ) throws Exception {
 
         for ( int i = 0; i < size; i++ ) {
             Map<String, Object> entity = new HashMap<String, Object>();
-            entity.put( "name", String.valueOf( i ) );
+            entity.put("name", String.valueOf(i));
 
-            io.writeEntity( entity );
+            io.writeEntity(entity);
             //we have to sleep, or we kill embedded cassandra
-            Thread.sleep( 10 );
 
         }
-
+        app.refreshIndex();
         long stop = System.currentTimeMillis();
 
         LOG.info( "Writes took {} ms", stop - start );
@@ -368,6 +367,7 @@ protected void singleOrderByIntersection( IoHelper io ) throws Exception {
             }
         }
         app.refreshIndex();
+        Thread.sleep(500);
 
 
         long stop = System.currentTimeMillis();
@@ -1126,7 +1126,7 @@ protected void allIn( IoHelper io ) throws Exception {
         LOG.info( "Writes took {} ms", stop - start );
 
         app.refreshIndex();
-        app.refreshIndex();
+        Thread.sleep(500);
 
         Query query = new Query();
         query.setLimit( 100 );