Repository: usergrid Updated Branches: refs/heads/master 3d6014529 -> 2af22a871
Make sure to create keyspaces on initialization before trying to obtain sessions to the keyspaces. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/2af22a87 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/2af22a87 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/2af22a87 Branch: refs/heads/master Commit: 2af22a87105629f423463c4132ff9141bb95930c Parents: 3d60145 Author: Michael Russo <[email protected]> Authored: Sun Nov 20 19:45:43 2016 -0800 Committer: Michael Russo <[email protected]> Committed: Sun Nov 20 19:45:43 2016 -0800 ---------------------------------------------------------------------- .../persistence/core/datastax/impl/DataStaxClusterImpl.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/2af22a87/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java index a9238e8..bd7d326 100644 --- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java +++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java @@ -51,9 +51,6 @@ public class DataStaxClusterImpl implements DataStaxCluster { public DataStaxClusterImpl(final CassandraConfig cassandraFig ) throws Exception { this.cassandraConfig = cassandraFig; this.cluster = getCluster(); - this.clusterSession = getClusterSession(); - this.applicationSession = getApplicationSession(); - this.queueMessageSession = getApplicationLocalSession(); logger.info("Initialized datastax cluster client. Hosts={}, Idle Timeout={}s, Pool Timeout={}s", getCluster().getMetadata().getAllHosts().toString(), @@ -62,6 +59,7 @@ public class DataStaxClusterImpl implements DataStaxCluster { // always initialize the keyspaces this.createApplicationKeyspace(false); + this.createApplicationLocalKeyspace(false); } @Override
