Skip to content


Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

fixed expiring shard bug, shardInfo was reading the wrong schema from…

… SI for local shards
  • Loading branch information...
commit 14dece46be45615d104a1996cf15a01e67c22ee3 1 parent 5dda037
@ceocoder authored
Showing with 1 addition and 1 deletion.
  1. +1 −1  src/lucandra/cluster/
2  src/lucandra/cluster/
@@ -239,7 +239,7 @@ private ShardInfo getShardInfo(String indexName, boolean force) throws IOExcepti
// goto each shard and get local offset
cmd = new SliceFromReadCommand(CassandraUtils.keySpace, CassandraUtils.hashKeyBytes((indexName
- + "~" + shardStr).getBytes("UTF-8"), CassandraUtils.delimeterBytes, "shards"
+ ).getBytes("UTF-8"), CassandraUtils.delimeterBytes, "shards"
.getBytes("UTF-8")), new ColumnParent(CassandraUtils.schemaInfoColumnFamily),
ByteBufferUtil.EMPTY_BYTE_BUFFER, ByteBufferUtil.EMPTY_BYTE_BUFFER, false, 100);
Please sign in to comment.
Something went wrong with that request. Please try again.