You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/09/11 18:29:05 UTC
usergrid git commit: Updated test logging
Repository: usergrid
Updated Branches:
refs/heads/USERGRID-909 db81a596c -> d823d817e
Updated test logging
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/d823d817
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/d823d817
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/d823d817
Branch: refs/heads/USERGRID-909
Commit: d823d817ea30428f8a18617a3c7d032bc6f98a99
Parents: db81a59
Author: Todd Nine <tn...@apigee.com>
Authored: Fri Sep 11 10:29:04 2015 -0600
Committer: Todd Nine <tn...@apigee.com>
Committed: Fri Sep 11 10:29:04 2015 -0600
----------------------------------------------------------------------
.../persistence/graph/GraphManagerShardConsistencyIT.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/d823d817/stack/corepersistence/graph/src/test/java/org/apache/usergrid/persistence/graph/GraphManagerShardConsistencyIT.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/graph/src/test/java/org/apache/usergrid/persistence/graph/GraphManagerShardConsistencyIT.java b/stack/corepersistence/graph/src/test/java/org/apache/usergrid/persistence/graph/GraphManagerShardConsistencyIT.java
index ef7e694..8fded10 100644
--- a/stack/corepersistence/graph/src/test/java/org/apache/usergrid/persistence/graph/GraphManagerShardConsistencyIT.java
+++ b/stack/corepersistence/graph/src/test/java/org/apache/usergrid/persistence/graph/GraphManagerShardConsistencyIT.java
@@ -79,7 +79,6 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
-//@Ignore( "Kills cassandra, needs to be part of functional testing" )
public class GraphManagerShardConsistencyIT {
private static final Logger log = LoggerFactory.getLogger( GraphManagerShardConsistencyIT.class );
@@ -155,7 +154,7 @@ public class GraphManagerShardConsistencyIT {
final int numInjectors = 4;
// final int numInjectors = 2;
- // final int numInjectors = 1;
+// final int numInjectors = 1;
/**
* create multiple injectors. This way all the caches are independent of one another. This is the same as
@@ -184,7 +183,7 @@ public class GraphManagerShardConsistencyIT {
final ListeningExecutorService executor =
- MoreExecutors.listeningDecorator( Executors.newFixedThreadPool( numWorkersPerInjector ) );
+ MoreExecutors.listeningDecorator( Executors.newFixedThreadPool( numWorkersPerInjector * numInjectors ) );
final AtomicLong writeCounter = new AtomicLong();
@@ -218,6 +217,8 @@ public class GraphManagerShardConsistencyIT {
future.get();
}
+ log.info( "Completed writing all edges for test, beginning read" );
+
//now get all our shards
final NodeShardGroupSearch cache = getInstance( injectors, NodeShardGroupSearch.class );
@@ -273,7 +274,6 @@ public class GraphManagerShardConsistencyIT {
//now start our readers
-
while ( true ) {
if ( !failures.isEmpty() ) {
@@ -332,6 +332,8 @@ public class GraphManagerShardConsistencyIT {
// }
break;
+ } else{
+ log.info( "Compactions not complete. Compacted {} shards", compactedCount );
}