You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/08/01 07:31:08 UTC
[james-project] 15/20: JAMES-2838 Parallelism do not play well with
error propagation
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 2c1db46f32dff67d86cc87449bb1c2816835aed9
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Tue Jul 30 09:10:36 2019 +0200
JAMES-2838 Parallelism do not play well with error propagation
Despite a long debug session. Hence I turned it off. Note that with IO
what we really need is prefetch, as we are not CPU bound.
---
.../main/java/org/apache/james/blob/cassandra/CassandraBlobStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobStore.java b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobStore.java
index 283c76b..653edef 100644
--- a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobStore.java
+++ b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobStore.java
@@ -52,7 +52,7 @@ import reactor.core.scheduler.Schedulers;
public class CassandraBlobStore implements BlobStore {
private static final int PREFETCH = 16;
- private static final int MAX_CONCURRENCY = 2;
+ private static final int MAX_CONCURRENCY = 1;
private final CassandraDefaultBucketDAO defaultBucketDAO;
private final CassandraBucketDAO bucketDAO;
private final DataChunker dataChunker;
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org