incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tyler Hobbs <ty...@riptano.com>
Subject Re: Updating Cascal
Date Tue, 30 Nov 2010 06:06:55 GMT
Are you sure you're using the same key for batch_mutate() and get_slice()?
They appear different in the logs.

- Tyler

On Thu, Nov 25, 2010 at 10:14 AM, Michael Fortin <mikee@m410.us> wrote:

> Hello,
> I forked Cascal  (Scala based client for cassandra) and I'm attempting to
> update it to cassandra 0.7.  I have it partially working, but I'm getting
> stuck on a few areas.
>
> I have most of the unit tests working from the original code, but I'm
> having an issue with batch_mutate(keyToFamilyMutations, consistency) .  Does
> the log output mean anything?  I can't figure out why the columns are not
> getting inserted.  If I change th code from a batch_mutate to an
> insert(family, parent, column, consistency) it works.
>
> ### keyToFamilyMutations: {java.nio.HeapByteBuffer[pos=0 lim=16
> cap=16]={Standard=[Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43
> 6F 6C 75 6D 6E 2D 61 2D 31, value:56 61 6C 75 65 2D 31,
> timestamp:1290662894466035))),
> Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43 6F
> 6C 75 6D 6E 2D 61 2D 33, value:56 61 6C 75 65 2D 33,
> timestamp:1290662894467942))),
> Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43 6F
> 6C 75 6D 6E 2D 61 2D 32, value:56 61 6C 75 65 2D 32,
> timestamp:1290662894467915)))]}}
> DEBUG 2010-11-25 00:28:14,534 [org.apache.cassandra.thrift.CassandraServer
> pool-1-thread-2] batch_mutate
> DEBUG 2010-11-25 00:28:14,583 [org.apache.cassandra.service.StorageProxy
> pool-1-thread-2] insert writing local RowMutation(keyspace='Test',
> key='ccfd5520f85411df858a001c42000009', modifications=[Standard])
>
> DEBUG 2010-11-25 00:28:14,599 [org.apache.cassandra.thrift.CassandraServer
> pool-1-thread-2] get_slice
> DEBUG 2010-11-25 00:28:14,605 [org.apache.cassandra.service.StorageProxy
> pool-1-thread-2] weakread reading SliceFromReadCommand(table='Test',
> key='5374616e64617264',
> column_parent='QueryPath(columnFamilyName='Standard',
> superColumnName='null', columnName='null')', start='', finish='',
> reversed=false, count=2147483647) locally
> DEBUG 2010-11-25 00:28:14,608 [org.apache.cassandra.service.StorageProxy
> ReadStage:2] weakreadlocal reading SliceFromReadCommand(table='Test',
> key='5374616e64617264',
> column_parent='QueryPath(columnFamilyName='Standard',
> superColumnName='null', columnName='null')', start='', finish='',
> reversed=false, count=2147483647)
> ### get_slice: []
>
>
> The code looks like:
>      println("keyToFamilyMutations: %s".format(keyToFamilyMutations))
>      client.batch_mutate(keyToFamilyMutations, consistency)
>      …
>      client.client.get_slice(…)
>
> keyspaces:
>    - name: Test
>      replica_placement_strategy:
> org.apache.cassandra.locator.SimpleStrategy
>      replication_factor: 1
>      column_families:
>        - {name: Standard, compare_with: BytesType}
>
>
>
> Thanks,
> Mike

Mime
View raw message