Author: jbellis
Date: Fri Aug 26 21:06:12 2011
New Revision: 1162255
URL: http://svn.apache.org/viewvc?rev=1162255&view=rev
Log:
fix UnavailableException with writes at CL.EACH_QUORM
patch by Patricio Echague; reviewed by jbellis for CASSANDRA-3082
Modified:
cassandra/branches/cassandra-0.7/CHANGES.txt
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java
Modified: cassandra/branches/cassandra-0.7/CHANGES.txt
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/CHANGES.txt?rev=1162255&r1=1162254&r2=1162255&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.7/CHANGES.txt Fri Aug 26 21:06:12 2011
@@ -1,3 +1,7 @@
+0.7.10
+ * fix UnavailableException with writes at CL.EACH_QUORM (CASSANDRA-3084)
+
+
0.7.9
* don't include tmp files as sstable when create cfs (CASSANDRA-2929)
* log Java classpath on startup (CASSANDRA-2895)
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java?rev=1162255&r1=1162254&r2=1162255&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java
(original)
+++
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java
Fri Aug 26 21:06:12 2011
@@ -113,7 +113,7 @@ public class DatacenterSyncWriteResponse
// Throw exception if any of the DC doesn't have livenodes to accept
write.
for (String dc: strategy.getDatacenters())
{
- if (dcEndpoints.get(dc).get() != responses.get(dc).get())
+ if (dcEndpoints.get(dc).get() < responses.get(dc).get())
throw new UnavailableException();
}
}
