This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit c1b2357a52e3f3b36cd5ea935d0612596b7665a1 Author: Benoit Tellier <btell...@linagora.com> AuthorDate: Thu Nov 7 16:59:39 2019 +0700 JAMES-2632 concatMap for mailbox search This slighlty decrease average performance of GetMailboxes but allows a much lower p99 and completly get rid of errors. Scenario: 13.706 req/s (GetMailboxes) Before: Average: 414 ms p99: 2104 ms Errors: 54 After: Average: 470 ms p99: 1723 ms Errors: 0 --- .../org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java index 56b32d3..09ed684 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java @@ -155,7 +155,7 @@ public class CassandraMailboxMapper implements MailboxMapper { private List<Mailbox> toMailboxes(MailboxQuery.UserBound query, Flux<CassandraIdAndPath> listUserMailboxes) { return listUserMailboxes .filter(idAndPath -> query.isPathMatch(idAndPath.getMailboxPath())) - .flatMap(this::retrieveMailbox) + .concatMap(this::retrieveMailbox) .collectList() .block(); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org