Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Merge branch 'master' of github.com:deanhiller/playorm

  • Loading branch information...
commit 3fdbd2d7393df0d01217026c441d2ffce280c9bc 2 parents cea429b + ada3ddf
Dean Hiller authored
View
2  src/main/java/com/alvazan/orm/layer0/base/CursorRow.java
@@ -78,7 +78,7 @@ public void afterLast() {
//breaking all queries that use that index.
RowNotFoundException exc = new RowNotFoundException("Your query="+query+" contained a value with a pk where that entity no longer exists in the nosql store");
//keyVal.setException(exc);
- log.warn("Not erroring out, just a warning, there is an index pointing to a non-existant row. Either the index is corrupt, or the data is not yet consistent, but might be eventually", exc);
+ log.warn("Not erroring out, just a warning, there is an index pointing to a non-existant row. The index is "+obj+". Either the index is corrupt, or the data is not yet consistent, but might be eventually", exc);
}
keyVal.setKey(obj);
} else {
View
8 src/main/java/com/alvazan/orm/layer9z/spi/db/cassandra/CassandraSession.java
@@ -38,6 +38,7 @@
import com.netflix.astyanax.MutationBatch;
import com.netflix.astyanax.connectionpool.OperationResult;
import com.netflix.astyanax.connectionpool.exceptions.ConnectionException;
+import com.netflix.astyanax.connectionpool.exceptions.TokenRangeOfflineException;
import com.netflix.astyanax.ddl.KeyspaceDefinition;
import com.netflix.astyanax.ddl.SchemaChangeResult;
import com.netflix.astyanax.model.ByteBufferRange;
@@ -137,7 +138,12 @@ public void sendChangesImpl(List<Action> actions, MetaLookup ormSession) throws
}
long time = System.currentTimeMillis();
- m.execute();
+ try {
+ m.execute();
+ } catch (TokenRangeOfflineException e) {
+ throw new RuntimeException(
+ "It appears your CL_LEVEL is CL_QUOROM and there are not enough nodes on line to service that request. Either lower your CL_LEVEL or make sure all nodes are operational");
+ }
if(log.isTraceEnabled()) {
long total = System.currentTimeMillis()-time;
Please sign in to comment.
Something went wrong with that request. Please try again.