JAMES-2472 Add a little fetchSize when cleaning Cassandra
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/40d18af2 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/40d18af2 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/40d18af2 Branch: refs/heads/master Commit: 40d18af21fcc4b762a917bbfee8c9cc5872eceae Parents: cbcebb4 Author: benwa <[email protected]> Authored: Fri Jul 20 12:56:22 2018 +0700 Committer: benwa <[email protected]> Committed: Fri Jul 20 18:18:14 2018 +0700 ---------------------------------------------------------------------- .../james/backends/cassandra/init/CassandraTableManager.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/40d18af2/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTableManager.java ---------------------------------------------------------------------- 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 dc4dc6b..0a9129c 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 @@ -70,7 +70,10 @@ public class CassandraTableManager { private CompletableFuture<?> truncate(CassandraAsyncExecutor executor, String name) { return executor.execute( - QueryBuilder.select().from(name).limit(1)) + QueryBuilder.select() + .from(name) + .limit(1) + .setFetchSize(1)) .thenCompose(resultSet -> truncateIfNeeded(executor, name, resultSet)); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
