Repository: james-project Updated Branches: refs/heads/master f96adca8d -> ed61657d2
JAMES-2133 revert parallel tables and types creation Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/ed61657d Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/ed61657d Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/ed61657d Branch: refs/heads/master Commit: ed61657d2b302d1cd51adac179d41fbf4c4e500b Parents: f96adca Author: Matthieu Baechler <matth...@apache.org> Authored: Tue Sep 12 12:09:48 2017 +0200 Committer: Matthieu Baechler <matth...@apache.org> Committed: Tue Sep 12 12:09:48 2017 +0200 ---------------------------------------------------------------------- .../james/backends/cassandra/init/CassandraTableManager.java | 1 - .../james/backends/cassandra/init/CassandraTypesCreator.java | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/ed61657d/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 2897035..95db5d9 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 @@ -35,7 +35,6 @@ public class CassandraTableManager { public CassandraTableManager ensureAllTables() { module.moduleTables() - .parallelStream() .forEach(table -> session.execute(table.getCreateStatement())); return this; } http://git-wip-us.apache.org/repos/asf/james-project/blob/ed61657d/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTypesCreator.java ---------------------------------------------------------------------- diff --git a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTypesCreator.java b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTypesCreator.java index 8154c71..db85376 100644 --- a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTypesCreator.java +++ b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/CassandraTypesCreator.java @@ -34,7 +34,7 @@ public class CassandraTypesCreator { } public void initializeTypes() { - types.parallelStream().forEach((type) -> session.execute(type.getCreateStatement())); + types.forEach((type) -> session.execute(type.getCreateStatement())); } } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
