Remove not needed parallelstream and set the default back pressure for indexing quorum reads to be 5 seconds.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/36a01617 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/36a01617 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/36a01617 Branch: refs/heads/master Commit: 36a01617cb88ff1d9c2c1499089b7a2d13cd6eb1 Parents: b06190a Author: Michael Russo <[email protected]> Authored: Wed Mar 9 14:14:16 2016 -0800 Committer: Michael Russo <[email protected]> Committed: Wed Mar 9 14:14:16 2016 -0800 ---------------------------------------------------------------------- .../corepersistence/asyncevents/AsyncEventServiceImpl.java | 2 +- .../main/java/org/apache/usergrid/persistence/queue/QueueFig.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/36a01617/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java index 3f623d8..200d1e6 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java @@ -285,7 +285,7 @@ public class AsyncEventServiceImpl implements AsyncEventService { logger.debug("callEventHandlers with {} message", messages.size()); } - Stream<IndexEventResult> indexEventResults = messages.parallelStream().map(message -> + Stream<IndexEventResult> indexEventResults = messages.stream().map(message -> { AsyncEvent event = null; http://git-wip-us.apache.org/repos/asf/usergrid/blob/36a01617/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java index 383ab80..a7d299e 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java @@ -84,7 +84,7 @@ public interface QueueFig extends GuicyFig { int getVisibilityTimeout(); @Key( "usergrid.queue.localquorum.timeout") - @Default("3000") // 3 seconds + @Default("5000") // 5 seconds int getLocalQuorumTimeout(); @Key( "usergrid.queue.client.connection.timeout")
