Update the threshold settings.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/2a89d2d9 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/2a89d2d9 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/2a89d2d9 Branch: refs/heads/asf-site Commit: 2a89d2d9a9f17c97724f5ca7f28822b4d6d74f0b Parents: 10ac8d0 Author: Michael Russo <mru...@apigee.com> Authored: Fri Sep 23 13:12:59 2016 -0700 Committer: Michael Russo <mru...@apigee.com> Committed: Fri Sep 23 13:12:59 2016 -0700 ---------------------------------------------------------------------- .../persistence/collection/uniquevalues/UniqueValuesRouter.java | 2 +- .../collection/uniquevalues/UniqueValuesServiceImpl.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/2a89d2d9/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesRouter.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesRouter.java b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesRouter.java index 7176202..47db3a5 100644 --- a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesRouter.java +++ b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesRouter.java @@ -44,7 +44,7 @@ public class UniqueValuesRouter extends UntypedActor { router = getContext().actorOf( FromConfig.getInstance() .props(Props.create(UniqueValueActor.class) - .withDispatcher("blocking-io-dispatcher")), "router"); + .withDispatcher("akka.blocking-io-dispatcher")), "router"); // TODO: is there some way to pass the injector here without getting this exception: // NotSerializableException: No configured serialization-bindings for class [InjectorImpl] http://git-wip-us.apache.org/repos/asf/usergrid/blob/2a89d2d9/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java index 8bdb02c..82dc8cc 100644 --- a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java +++ b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java @@ -344,8 +344,8 @@ public class UniqueValuesServiceImpl implements UniqueValuesService { put( "use-role", "io" ); put( "max-nr-of-instances-per-node", numInstancesPerNode ); put( "failure-detector", new HashMap<String, Object>() {{ - put( "threshold", "10" ); - put( "acceptable-heartbeat-pause", "3 s" ); + put( "threshold", "20" ); + put( "acceptable-heartbeat-pause", "6 s" ); put( "heartbeat-interval", "1 s" ); put( "heartbeat-request", new HashMap<String, Object>() {{ put( "expected-response-after", "3 s" );
