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
The following commit(s) were added to refs/heads/master by this push:
new 2a6fd18 JAMES-3622 Compatibility with Cassandra 4.0.0
new 41fa96c Merge pull request #558 from chibenwa/cassandra-4
2a6fd18 is described below
commit 2a6fd188b26ddeaf30488fd4596b2bdc9dd402cb
Author: Benoit Tellier <[email protected]>
AuthorDate: Thu Jul 29 15:34:11 2021 +0700
JAMES-3622 Compatibility with Cassandra 4.0.0
---
.../apache/james/backends/cassandra/components/CassandraModule.java | 6 +-----
.../apache/james/blob/cassandra/cache/CassandraBlobCacheModule.java | 3 +--
.../queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java | 6 ++----
3 files changed, 4 insertions(+), 11 deletions(-)
diff --git
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/components/CassandraModule.java
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/components/CassandraModule.java
index 3f564a1..792bb6b 100644
---
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/components/CassandraModule.java
+++
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/components/CassandraModule.java
@@ -108,8 +108,6 @@ public interface CassandraModule {
}
class TableBuilder {
- private static final double DISABLED = 0d;
-
private final Builder originalBuilderReference;
private final String tableName;
private Optional<String> comment;
@@ -145,9 +143,7 @@ public interface CassandraModule {
new CassandraTable(tableName,
options.orElse(Function.identity())
.apply(createStatement.withOptions()
- .comment(comment.get())
- .readRepairChance(DISABLED)
- .dcLocalReadRepairChance(DISABLED))));
+ .comment(comment.get()))));
}
}
diff --git
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CassandraBlobCacheModule.java
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CassandraBlobCacheModule.java
index d6e63a9..31f1266 100644
---
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CassandraBlobCacheModule.java
+++
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CassandraBlobCacheModule.java
@@ -40,8 +40,7 @@ public interface CassandraBlobCacheModule {
.compactionOptions(SchemaBuilder.timeWindowCompactionStrategy()
.compactionWindowSize(1)
.compactionWindowUnit(HOURS))
- .compressionOptions(SchemaBuilder.lz4().withChunkLengthInKb(8))
- .readRepairChance(NO_READ_REPAIR))
+ .compressionOptions(SchemaBuilder.lz4().withChunkLengthInKb(8)))
.comment("Write through cache for small blobs stored in a slower blob
store implementation.")
.statement(statement -> statement
.addPartitionKey(ID, DataType.text())
diff --git
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java
index 2c644d6..1d647bb 100644
---
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java
+++
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java
@@ -98,8 +98,7 @@ public interface CassandraMailQueueViewModule {
.options(options -> options
.compactionOptions(SchemaBuilder.timeWindowCompactionStrategy()
.compactionWindowSize(1)
- .compactionWindowUnit(HOURS))
- .readRepairChance(NO_READ_REPAIR))
+ .compactionWindowUnit(HOURS)))
.statement(statement -> statement
.addPartitionKey(EnqueuedMailsTable.QUEUE_NAME, text())
.addPartitionKey(EnqueuedMailsTable.TIME_RANGE_START, timestamp())
@@ -142,8 +141,7 @@ public interface CassandraMailQueueViewModule {
"existence in this table")
.options(options -> options
.compactionOptions(SchemaBuilder.timeWindowCompactionStrategy())
- .bloomFilterFPChance(0.01)
- .readRepairChance(NO_READ_REPAIR))
+ .bloomFilterFPChance(0.01))
.statement(statement -> statement
.addPartitionKey(DeletedMailTable.QUEUE_NAME, text())
.addPartitionKey(DeletedMailTable.ENQUEUE_ID, uuid()))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
