gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject svn commit: r1236159 - in /incubator/gora/trunk: CHANGES.txt gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
Date Thu, 26 Jan 2012 12:36:54 GMT
Author: lewismc
Date: Thu Jan 26 12:36:54 2012
New Revision: 1236159

URL: http://svn.apache.org/viewvc?rev=1236159&view=rev
Log:
commit to address GORA-79 & update to CHANGES.txt

Modified:
    incubator/gora/trunk/CHANGES.txt
    incubator/gora/trunk/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java

Modified: incubator/gora/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/gora/trunk/CHANGES.txt?rev=1236159&r1=1236158&r2=1236159&view=diff
==============================================================================
--- incubator/gora/trunk/CHANGES.txt (original)
+++ incubator/gora/trunk/CHANGES.txt Thu Jan 26 12:36:54 2012
@@ -1,6 +1,9 @@
 Gora Change Log
 
 Trunk (unreleased changes):
+
+* GORA-79 Block keyspace creation until the whole cassandra cluster converges to the new
keyspace. (Patricio Echagüe vis lewismc)
+
 * GORA-83 add 'target' dirs to svn ignore (ferdy)
 
 * GORA-66 testDeleteByQueryFields seems incorrect (Keith Turner via lewismc)

Modified: incubator/gora/trunk/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
URL: http://svn.apache.org/viewvc/incubator/gora/trunk/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java?rev=1236159&r1=1236158&r2=1236159&view=diff
==============================================================================
--- incubator/gora/trunk/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
(original)
+++ incubator/gora/trunk/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
Thu Jan 26 12:36:54 2012
@@ -82,7 +82,7 @@ public class CassandraClient<K, T extend
     if (keyspaceDefinition == null) {
       List<ColumnFamilyDefinition> columnFamilyDefinitions = this.cassandraMapping.getColumnFamilyDefinitions();
     
       keyspaceDefinition = HFactory.createKeyspaceDefinition(this.cassandraMapping.getKeyspaceName(),
"org.apache.cassandra.locator.SimpleStrategy", 1, columnFamilyDefinitions);      
-      this.cluster.addKeyspace(keyspaceDefinition);
+      this.cluster.addKeyspace(keyspaceDefinition, true);
       LOG.info("Keyspace '" + this.cassandraMapping.getKeyspaceName() + "' in cluster '"
+ this.cassandraMapping.getClusterName() + "' was created on host '" + this.cassandraMapping.getHostName()
+ "'");
       
       keyspaceDefinition = null;



Mime
View raw message