Permalink
Browse files

ignore shards already taken by other tokens

  • Loading branch information...
1 parent da2edc3 commit 8fefd06a90c0960892334506b92de448ad84616e @tjake committed Jul 6, 2011
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/lucandra/cluster/CassandraIndexManager.java
@@ -673,7 +673,7 @@ private Long nextReservedId(String indexName, NodeInfo[] shards, String myToken)
{
if(usedNodeInfo.nodes.get(""+nextOffset) != null)
{
- CassandraUtils.robustInsert(ConsistencyLevel.QUORUM, updateNodeOffset(indexName, myToken, node.shard, nextOffset));
+ updateNodeOffset(indexName, myToken, node.shard, nextOffset);
// try next offset

0 comments on commit 8fefd06

Please sign in to comment.