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 2c4242c JAMES-3651 CassandraTableManager::cleanup need to be
resilient in the face of massive tombstones (#658)
2c4242c is described below
commit 2c4242c3f8c748582c0c09babb3fec5041970a4f
Author: Benoit TELLIER <[email protected]>
AuthorDate: Sat Sep 18 16:30:49 2021 +0700
JAMES-3651 CassandraTableManager::cleanup need to be resilient in the face
of massive tombstones (#658)
---
.../apache/james/backends/cassandra/init/CassandraTableManager.java | 3 ++-
1 file changed, 2 insertions(+), 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 41069fb..0c3bd8c 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
@@ -79,6 +79,7 @@ public class CassandraTableManager {
.limit(1)
.setFetchSize(1))
.filter(Predicate.not(PagingIterable::isExhausted))
- .flatMap(ignored ->
executor.executeVoid(QueryBuilder.truncate(name)));
+ .flatMap(ignored ->
executor.executeVoid(QueryBuilder.truncate(name)))
+ .onErrorResume(e ->
executor.executeVoid(QueryBuilder.truncate(name)));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
