You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2020/11/04 02:16:55 UTC
[james-project] 03/09: MAILBOX-339 Limit concurency for migration
processes
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 <bt...@linagora.com>
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: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org