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 cd9f2885770a32eca5418160742bc8dd50e9e2fc Author: Benoit Tellier <[email protected]> AuthorDate: Mon Nov 2 13:51:49 2020 +0100 MAILBOX-339 Limit concurency for migration processes --- .../james/mailbox/cassandra/mail/migration/MailboxPathV2Migration.java | 3 ++- .../james/mailbox/cassandra/mail/migration/MailboxPathV3Migration.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV2Migration.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV2Migration.java index 46c3fc2..d95487b 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV2Migration.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV2Migration.java @@ -89,6 +89,7 @@ public class MailboxPathV2Migration implements Migration { public static final Logger LOGGER = LoggerFactory.getLogger(MailboxPathV2Migration.class); public static final TaskType TYPE = TaskType.of("cassandra-mailbox-path-v2-migration"); + private static final int CONCURRENCY = 50; private final CassandraMailboxPathDAOImpl daoV1; private final CassandraMailboxPathV2DAO daoV2; private final long initialCount; @@ -103,7 +104,7 @@ public class MailboxPathV2Migration implements Migration { @Override public void apply() { daoV1.readAll() - .flatMap(this::migrate) + .flatMap(this::migrate, CONCURRENCY) .doOnError(t -> LOGGER.error("Error while performing migration", t)) .blockLast(); } diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV3Migration.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV3Migration.java index ccd727c..afe5e63 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV3Migration.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/migration/MailboxPathV3Migration.java @@ -90,6 +90,7 @@ public class MailboxPathV3Migration implements Migration { public static final Logger LOGGER = LoggerFactory.getLogger(MailboxPathV3Migration.class); public static final TaskType TYPE = TaskType.of("cassandra-mailbox-path-v3-migration"); + private static final int CONCURRENCY = 50; private final CassandraMailboxPathV2DAO daoV2; private final CassandraMailboxPathV3DAO daoV3; private final CassandraMailboxDAO mailboxDAO; @@ -106,7 +107,7 @@ public class MailboxPathV3Migration implements Migration { @Override public void apply() { daoV2.listAll() - .flatMap(this::migrate) + .flatMap(this::migrate, CONCURRENCY) .doOnError(t -> LOGGER.error("Error while performing migration", t)) .blockLast(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
