changing tests to iterate fewer times
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/d36689ca Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/d36689ca Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/d36689ca Branch: refs/heads/USERGRID-347 Commit: d36689ca8637514f78e0a79d95dec2a8c6641f22 Parents: 00d7aba Author: Shawn Feldman <[email protected]> Authored: Fri Mar 20 15:17:25 2015 -0600 Committer: Shawn Feldman <[email protected]> Committed: Fri Mar 20 15:17:25 2015 -0600 ---------------------------------------------------------------------- .../query/IntersectionTransitivePagingIT.java | 2 +- .../query/IntersectionUnionPagingIT.java | 2 +- .../persistence/query/IteratingQueryIT.java | 28 ++++++++++---------- .../impl/EsApplicationEntityIndexImpl.java | 1 + 4 files changed, 17 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d36689ca/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionTransitivePagingIT.java ---------------------------------------------------------------------- diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionTransitivePagingIT.java b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionTransitivePagingIT.java index af7c401..195ccdb 100644 --- a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionTransitivePagingIT.java +++ b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionTransitivePagingIT.java @@ -90,7 +90,7 @@ public class IntersectionTransitivePagingIT{ io.doSetup(); - int writeSize =200; + int writeSize = 10; List<UUID> expected = new ArrayList<UUID>(writeSize); http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d36689ca/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionUnionPagingIT.java ---------------------------------------------------------------------- diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionUnionPagingIT.java b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionUnionPagingIT.java index 146b591..b78bc46 100644 --- a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionUnionPagingIT.java +++ b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IntersectionUnionPagingIT.java @@ -93,7 +93,7 @@ public class IntersectionUnionPagingIT { private Set<String> performSetup( final IoHelper io ) throws Exception { io.doSetup(); - int size = 200; + int size =10; long start = System.currentTimeMillis(); http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d36689ca/stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java ---------------------------------------------------------------------- diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java index f4c5c0e..c73b776 100644 --- a/stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java +++ b/stack/core/src/test/java/org/apache/usergrid/persistence/query/IteratingQueryIT.java @@ -407,7 +407,7 @@ public class IteratingQueryIT { protected void singleOrderByComplexIntersection( IoHelper io ) throws Exception { - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -481,7 +481,7 @@ public class IteratingQueryIT { protected void singleOrderByNoIntersection( IoHelper io ) throws Exception { io.doSetup(); - int size = 200; + int size = 5; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -529,7 +529,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -599,7 +599,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -669,7 +669,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; int matchMax = queryLimit - 1; @@ -729,7 +729,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 100; int startValue = 100; @@ -791,7 +791,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 50; int startValue = 100; @@ -853,7 +853,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 100; int startValue = 100; @@ -914,7 +914,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 100; int startValue = 99; @@ -975,7 +975,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 100; int startValue = 50; int endValue = 150; @@ -1038,7 +1038,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = 100; int startValue = 50; int endValue = 150; @@ -1159,7 +1159,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -1266,7 +1266,7 @@ public class IteratingQueryIT { io.doSetup(); - int size = 200; + int size = 10; int queryLimit = Query.MAX_LIMIT; // the number of entities that should be written including an intersection @@ -1378,7 +1378,7 @@ public class IteratingQueryIT { /** * Leave this as a large size. We have to write over 1k to reproduce this issue */ - int size = 200; + int size = 10; long start = System.currentTimeMillis(); http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d36689ca/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java index de29e83..56f8030 100644 --- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java +++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java @@ -293,6 +293,7 @@ public class EsApplicationEntityIndexImpl implements ApplicationEntityIndex{ }); return Observable.from(response); }) + .doOnError( t -> logger.error("Failed on delete application",t)) .doOnCompleted(() -> timer.stop()); }
