You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2022/09/22 02:49:09 UTC
[james-project] branch master updated: [STABILITY] Limit number of threads in parallel when creating cassandra tables
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new b942300ede [STABILITY] Limit number of threads in parallel when creating cassandra tables
b942300ede is described below
commit b942300ede9f6f40614696ae1a0bf65f45473e69
Author: Rene Cordier <rc...@linagora.com>
AuthorDate: Wed Sep 21 14:44:20 2022 +0700
[STABILITY] Limit number of threads in parallel when creating cassandra tables
---
.../org/apache/james/backends/cassandra/init/CassandraTableManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
index 498e750d24..384a5a64fc 100644
--- a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
+++ b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java
@@ -52,7 +52,7 @@ public class CassandraTableManager {
KeyspaceMetadata keyspaceMetadata = session.getMetadata().getKeyspaces().get(session.getKeyspace().get());
return Flux.fromIterable(module.moduleTables())
- .flatMap(table -> table.initialize(keyspaceMetadata, session, typesProvider))
+ .flatMap(table -> table.initialize(keyspaceMetadata, session, typesProvider), DEFAULT_CONCURRENCY)
.reduce(InitializationStatus::reduce)
.switchIfEmpty(Mono.just(InitializationStatus.ALREADY_DONE))
.block();
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org