Merge pull request #626 from keyurkarnik/master

USERGRID-1348 : Fix failure for CollectionDeleteTest

Author: keyurkarnik

stack/Jenkinsfile

@@ -15,6 +15,7 @@
  * limitations under the License.
  */
 
+
 pipeline {
     agent { label 'ubuntu' }
 
@@ -24,7 +25,7 @@ pipeline {
     }
 
     options {
-          timeout(time: 30, unit: 'MINUTES')
+          timeout(time: 120, unit: 'MINUTES')
       }
 
 
@@ -70,7 +71,7 @@ pipeline {
             steps {
                 git 'https://github.com/apache/usergrid.git'
                 sh '''
-                    mvn clean install -DskipTests=true -f stack/pom.xml
+                    mvn clean install -f stack/pom.xml
                 '''
             }
         }
@@ -82,7 +83,7 @@ pipeline {
             junit 'stack/**/surefire-reports/*.xml'
             sh 'ps -ef | grep cassandra'
             sh 'ps -ef | grep elastic'
-            deleteDir() /* clean up our workspace */
+            deleteDir()  /*clean up our workspace */
         }
         success {
             echo 'Usergrid build and tests succeeded'
@@ -93,7 +94,3 @@ pipeline {
 
     }
 }
-
-
-
-

stack/core/src/test/java/org/apache/usergrid/persistence/CollectionDeleteTest.java

@@ -38,18 +38,16 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.codahale.metrics.MetricRegistry;
 
 
 
 public class CollectionDeleteTest extends AbstractCoreIT {
     private static final Logger logger = LoggerFactory.getLogger( CollectionDeleteTest.class );
 
-    private static final MetricRegistry registry = new MetricRegistry();
 
 
-    private static final int ENTITIES_TO_DELETE = 1000;
-    private static final int ENTITIES_TO_ADD_AFTER_TIME = 3;
+    private static final int ENTITIES_TO_DELETE = 1100;
+    private static final int ENTITIES_TO_ADD_AFTER_TIME = 5;
 
 
     @Before
@@ -97,43 +95,47 @@ public void clearOneCollection() throws Exception {
             final Entity entity;
 
             try {
-                entityMap.put( "key", i );
+                entityMap.put( "key", i+1 );
                 entity = em.create(itemType, entityMap);
             }
             catch ( Exception ex ) {
                 throw new RuntimeException( "Error creating entity", ex );
             }
 
             entityRefs.add( new SimpleEntityRef( entity.getType(), entity.getUuid() ) );
-            if ( i % 10 == 0 ) {
-                logger.info( "Created {} entities", i );
+            if ( (i+1) % 10 == 0 ) {
+                logger.info( "Created {} entities", i+1 );
             }
         }
 
-        logger.info("Created {} entities", ENTITIES_TO_DELETE);
 
         app.waitForQueueDrainAndRefreshIndex(10000);
 
         long timeFirstPutDone = System.currentTimeMillis();
-        logger.info("timeFirstPutDone={}", timeFirstPutDone);
+        logger.info("Finished adding first lot of entities at {}", timeFirstPutDone);
+
+        try {
+            //Wait to make sure that the time on the next entry changes
+            Thread.sleep(2000);
+        }
+        catch (Exception e) {
+        }
 
         for (int i = 0; i < ENTITIES_TO_ADD_AFTER_TIME; i++) {
 
             final Entity entity;
 
             try {
-                entityMap.put( "key", ENTITIES_TO_DELETE + i );
+                entityMap.put("key", ENTITIES_TO_DELETE + i+1);
                 entity = em.create(itemType, entityMap);
-            }
-            catch ( Exception ex ) {
-                throw new RuntimeException( "Error creating entity", ex );
+            } catch (Exception ex) {
+                throw new RuntimeException("Error creating entity", ex);
             }
 
-            entityRefs.add( new SimpleEntityRef( entity.getType(), entity.getUuid() ) );
-            logger.info( "Created {} entities after delete time created time {} ", i , entity.getCreated());
+            entityRefs.add(new SimpleEntityRef(entity.getType(), entity.getUuid()));
+            logger.info("Created {} entities after delete time with key {} and uuid {} at {} ", i + 1, entity.getProperty("key"), entity.getUuid(), entity.getCreated());
 
         }
-        logger.info("Created {} entities after delete time", ENTITIES_TO_ADD_AFTER_TIME);
 
 
         app.waitForQueueDrainAndRefreshIndex(15000);
@@ -238,7 +240,7 @@ private int readData(EntityManager em, String collectionName, int expectedEntiti
                 }
                 lastEntityUUID = e.getUuid();
                 uniqueRemEnts.add(e);
-                logger.info("Found remaining entity {}", lastEntityUUID);
+                logger.info("Found remaining entity {} with key {}", lastEntityUUID, e.getProperty("key"));
             }
 
             results = em.getCollection(em.getApplicationRef(), collectionName, lastEntityUUID, expectedEntities,
@@ -250,7 +252,7 @@ private int readData(EntityManager em, String collectionName, int expectedEntiti
             logger.info("Expected {} did not match actual {}", expectedEntities, uniqueRemEnts.size());
             if (uniqueRemEnts.size() < 20) {
                 for (Entity e : uniqueRemEnts) {
-                    Object key = e.getProperty("key2");
+                    Object key = e.getProperty("key");
                     logger.info("Entity key {} uuid {} created {}", key,e.getUuid(), e.getCreated());
                 }
             }