Pelops Mutator Exception for Bytes row key

9 views
Skip to first unread message

mpan

unread,
Feb 3, 2011, 11:38:11 AM2/3/11
to Scale 7 - Libraries and systems for scalable computing
When I use a Bytes row key instead of a string, I get an exception:

org.scale7.cassandra.pelops.exceptions.ApplicationException: Internal
error processing batch_mutate
at org.scale7.cassandra.pelops.exceptions.IExceptionTranslator
$ExceptionTranslator.translate(IExceptionTranslator.java:25)
at org.scale7.cassandra.pelops.Operand.tryOperation(Operand.java:67)

Code is here:
org.scale7.cassandra.pelops.Mutator mutator =
Pelops.createMutator(ClientEventDao.CASSANDRA_POOL);
List<Column> cols = new ArrayList<Column>();
cols.add(mutator.newColumn(USER_COLUMN, username));
cols.add(mutator.newColumn(CHANNEL_COLUMN, channel));
mutator.writeColumns(USER_ACTIONS_COLUMN_FAMILY,
Bytes.fromLong(timestamp), cols);
mutator.execute(CL_ONE);

Column Family Definition:
ColumnFamily: UserActions
Columns sorted by: org.apache.cassandra.db.marshal.BytesType
Row cache size / save period: 0.0/0
Key cache size / save period: 0.0/0
Memtable thresholds: 0.11249999999999999/24/60
GC grace seconds: 864000
Compaction min/max thresholds: 4/32
Read repair chance: 1.0

Dan Washusen

unread,
Feb 3, 2011, 4:29:25 PM2/3/11
to sca...@googlegroups.com
Hi Michael,
Any chance you could provide a little more detail (full stacktrace with the root cause would be good) or preferably a test case (see MutatorIntegrationTest)?

MutatorIntegrationTest#testWriteSubColumnsWithDeletesReplacingPrevious looks very similar to your code snippet below.  It would be excellent if you could narrow down and highlight the exact cause of your error...

Cheers,
Dan
Reply all
Reply to author
Forward
0 new messages