Re: CDH4 + Cassandra 1.2 Integration Issue

Ah ha. So, the client defaults to CQL 2. Anyway of changing that? I tired libthrift 0.9 as well but it doesn't work. Thanks. On Tue, Apr 9, 2013 at 11:29 PM, Shamim wrote: > Hello, > if you created your table with cql then you have to add COMPACT > STORAGE as follows: > CREATE TABLE user (

Re: CDH4 + Cassandra 1.2 Integration Issue

Hello,   if you created your table with cql then you have to add COMPACT STORAGE as follows: CREATE TABLE user (   id int PRIMARY KEY,   age int,   fname text,   lname text ) WITH COMPACT STORAGE -- Best regards   Shamim A. 10.04.2013, 08:22, "Gurminder Gill" : > I was able to start a MR

CDH4 + Cassandra 1.2 Integration Issue

I was able to start a MR job after patching Cassandra.Hadoop as per CASSANDRA-5201 . But then, ColumnFamilyRecordReader pukes within the MapTask. It is unable to read CF definition in the sample keyspace. The CF "user" does exist. *How can "cf

Cassandra 1.2.2 cluster + raspberry

Hi, I'm trying to set up a cassandra cluster for some experiments on my raspberry pies but I'm still having trouble to join my nodes to the cluster. I started with two nodes (192.168.2.3 and 192.168.2.7) and when I start the cassandra, I see the following exception on the node 192.168.2.7 ERROR [

Re: High gossip traffic volume on 1.1.9

> gossip traffic That was imprecise, I should have said port 7000 instead of 'gossip'. I got some help on irc, and it may have been a read repair, but not sure. What was interesting was the internal load relative to anything happening externally (120Mbps+ on 7000 compared to ~500Kbps on 9160)

High gossip traffic volume on 1.1.9

A test 3 node cluster I'm running, managed by Priam, has 'suddenly' seen its gossip traffic fly up, peaking at 120mbps. Looking at tcpdump it seems there is simply a high rate of gossip traffic. There's nothing obviously wrong the cluster itself; it's barely loaded, no markdowns/hints/gc and all

RE: other questions about // RE: batch_mutate

When the coordinator node receives a batch_mutate for __one__ row key associated with different mutations for different CF : Is it true the coordinator node treats them as __independent__ communications/requests to replicas (even if in that case, the replicas are the same for every request) ?

Thrift message length exceeded

Hello, We have recently upgraded to Cass 1.2.3 from Cass 1.1.5. We ran sstableupgrades and got the ring on its feet and we are now seeing a new issue. When we run MapReduce jobs against practically any table we find the following errors: 2013-04-09 09:58:47,746 INFO org.apache.hadoop.util.Nat

RE: data modeling from batch_mutate point of view

Thanks Aaron. It helped. Let's me rephrase a little bit my questions. It's about data modeling impact on "batch_mutate" advantages. I have one CF for storing data, and ~10 (all different) CF used for indexing that data. when adding a piece of data, I need to add indexes too, and then, I need

Column index vs Row index vs Denormalizing

Hi all, We are working on a data model for storing tweets for multiple streams (where a stream is defined by a number of keyword filters on the full twitter firehose), and retrieving the tweets by timestamp and hashtag. My question is whether the following data model would a good way for doing tha

Added column does not sort as the last column at

Hi All, I just upgraded from Cassandra 1.1.7 to 1.2.3 and im now seeing a lot of the following error in my output.log, cant find much on the web about it: ERROR 11:56:01,317 Exception in thread Thread[ReadStage:7236,5,main] java.lang.AssertionError: Added column does not sort as the last column a

Illegal Argument Exception

C* 1.2.3 , three node cluster. Yesterday we stumbled upon this error, and it's the first time we ever see it: ERROR [ReadStage:13918] 2013-04-08 21:09:54,714 CassandraDaemon.java (line 164) Exception in thread Thread[ReadStage:13918,5,main] java.lang.RuntimeException: java.lang.IllegalArgumentEx

Re: ERROR service.AbstractCassandraDaemon: Exception in thread Thread[Thrift:4,5,main]

> Do not heve any manner to limit the usage of heap by setting some attribute > in cassandra.yalm file? No use cassandra-env.sh, normally in /etc/cassandra , there are comments in the file. Cheers - Aaron Morton Freelance Cassandra Consultant New Zealand @aaronmorton http://ww

Re: data modeling from batch_mutate point of view

> So, one alternative design for indexing CF could be: > rowkey = folder_id > colname = (indexed value, timestamp, file_id) > colvalue = "" > If you always search in a folder what about rowkey = colname = (That's closer to secondary indexes in cassandra with the addition of the folder_id) >

Re: Issues running Bulkloader program on AIX server

Frame size may be small. See cassandra env for help. Segments broken now. https://github.com/apache/cassandra/blob/cassandra-1.2/conf/cassandra-env.sh#L187 Cheers - Aaron Morton Freelance Cassandra Consultant New Zealand @aaronmorton http://www.thelastpickle.com On 9/04/2013

Re: Cassandra services down frequently [Version 1.1.4]

> MAX_HEAP_SIZE="6G" > HEAP_NEWSIZE="500M" The new heap feels a little low, I often see 800M as a good number. It depends on the number of cores, but if that's working stick with it. > key_cache_size_in_mb: 512 Have you run this at the default and checked the cache hit rate using nodetool info

Re: CQL3 dynamic CF design questions

> Which would lead to the storage engine storing rows similar to this (AFAIK): > > 8b2c0b60-977a-11e2-99c2-c8bcc8dc5d1d > - basic_info:propertyset_val = { firstName:"john", lastName:"smith", ...} > - contact_info:propertyset_val = { address: {streetAddr:"1 infinite loop", > postalCode: ""}, ... }