Re: Problem with Cassandra 2.1 and Spark 1.2.1

2015-02-24 Thread Nate McCall
You can use the "spark.cassandra.connection.local_dc" to restrict the query to a single data center. It might just be that you can't access the remote DC from the IP address returned internally when the client attempts to discover ring topology. On Mon, Feb 23, 2015 at 4:52 PM, Bosung Seo wrote:

Re: CollationController not using collectTimeOrderedData

2015-02-24 Thread Michael Mior
Thanks Robert! https://issues.apache.org/jira/browse/CASSANDRA-8859 2015-02-24 14:06 GMT-05:00 Robert Coli : > On Tue, Feb 24, 2015 at 10:58 AM, Michael Mior > wrote: > >> I'd appreciate some help with a Cassandra 2.1.2 issue I'm experiencing. >> I'm running a query which looks like this: >> ..

Re: CollationController not using collectTimeOrderedData

2015-02-24 Thread Robert Coli
On Tue, Feb 24, 2015 at 10:58 AM, Michael Mior wrote: > I'd appreciate some help with a Cassandra 2.1.2 issue I'm experiencing. > I'm running a query which looks like this: > ... > > However, when I run the query with tracing, I see that Cassandra still > reads from ALL of the SSTables via coll

CollationController not using collectTimeOrderedData

2015-02-24 Thread Michael Mior
Hi all, I'd appreciate some help with a Cassandra 2.1.2 issue I'm experiencing. I'm running a query which looks like this: CREATE TABLE single_row_fetch (id uuid PRIMARY KEY, data text) SELECT data FROM single_row_fetch WHERE id = ? When writing test data into this table, I disabled compaction.

Re: Cassandra Read Timeout

2015-02-24 Thread Robert Coli
On Tue, Feb 24, 2015 at 8:50 AM, Yulian Oifa wrote: > The structure is the same , the CFs are super column CFs , where key is > long ( timestamp to partition the index , so each 11 days new row is > created ) , super Column is int32 and columns / values are timeuuids.I am > running same queries

how to scan all rows of cassandra using multiple threads

2015-02-24 Thread Gaurav Bhatnagar
Hi, I have a cassandra cluster of 3 nodes holding around 300 million rows of items. I have a replication factor of 3 with read/write consistency as Quorum. I want to scan all rows of database to generate sum of items having value "available" in column name state and value "batch1" in column na

Re: Cassandra Read Timeout

2015-02-24 Thread Marcelo Valle (BLOOMBERG/ LONDON)
I am sorry, not sure if I will be able to help you. I am not familiar with super columns, I would tell you to try to get rid of them as soon as possible. Maybe someone else in the list can help you. Anyway, it really seems you have a cell with a very large amount of data and the request might be

Re: Cassandra Read Timeout

2015-02-24 Thread Yulian Oifa
Hello I am running 1.2.19 Best regards Yulian Oifa On Tue, Feb 24, 2015 at 6:57 PM, Marcelo Valle (BLOOMBERG/ LONDON) < mvallemil...@bloomberg.net> wrote: > Super column? Out of curiosity, which Cassandra version are you running? > > > From: user@cassandra.apache.org > Subject: Re: Cassandra Read

Re: Cassandra Read Timeout

2015-02-24 Thread Marcelo Valle (BLOOMBERG/ LONDON)
Super column? Out of curiosity, which Cassandra version are you running? From: user@cassandra.apache.org Subject: Re: Cassandra Read Timeout Hello The structure is the same , the CFs are super column CFs , where key is long ( timestamp to partition the index , so each 11 days new row is creat

Re: Cassandra Read Timeout

2015-02-24 Thread Yulian Oifa
Hello The structure is the same , the CFs are super column CFs , where key is long ( timestamp to partition the index , so each 11 days new row is created ) , super Column is int32 and columns / values are timeuuids.I am running same queries , getting reversed slice by raw key and super column. Th

Re: Cassandra Read Timeout

2015-02-24 Thread Marcelo Valle (BLOOMBERG/ LONDON)
Indeed, I thought something odd could be happening to your cluster, but it seems it's working fine but the request is taking too long to complete. I noticed from your cfstats the read count was about 10 in the first CF and in the second one it was about 1000... Would you be doing much more read

Re: Cassandra Read Timeout

2015-02-24 Thread Yulian Oifa
Hello TP STATS Before Request: Pool NameActive Pending Completed Blocked All time blocked ReadStage 0 0*7592835* 0 0 RequestResponseStage 0 0 0 0 0 MutationStage

Re:Cassandra Read Timeout

2015-02-24 Thread Marcelo Valle (BLOOMBERG/ LONDON)
Yulian, Maybe other people have other clues, but I think if you could monitor the behavior in tpstats after activity "Seeking to partition beginning in data file" it could help to find the problem. Which type of thread is getting stuck? Do you see any number increasing continuously during the r

Cassandra Read Timeout

2015-02-24 Thread Yulian Oifa
Hello to all I have single node cassandra on amazon ec2. Currently i am having a read timeout problem on single CF , single raw. Raw size is aroung 190MB.There are bigger raws with similar structure ( its index raws , which actually stores keys ) and everything is working fine on them, everything

Re: Many pending compactions

2015-02-24 Thread Ja Sam
The repair results is following (we run it Friday): Cannot proceed on repair because a neighbor (/192.168.61.201) is dead: session failed But to be honest the neighbor did not died. It seemed to trigger a series of full GC events on the initiating node. The results form logs are: [2015-02-20 16:4

RE: Efficient .net client for cassandra

2015-02-24 Thread Ashic Mahtab
Hi Asit,While I haven't used stratio's lucene indexing, a few points on the datastax .net connector: i) It got a major revamp last year. I'm assuming you're using the latest one?ii) Are prepared statements actually being reused many times? If not, perhaps the overhead isn't worth it. Prepared st

Re: build failure with cassandra 2.0.12

2015-02-24 Thread Asit KAUSHIK
I got this error when i had the below issues Java was of 1.8 version i downgraded to *jdk1.7.0_65* Also as you say you have both Maven and Ant install i got when either of them was not installed as i was building using ANT. Hope this helps *Regards* *Asit* .7.0_65 On Tue, Feb 24, 2015 at 2:59

Fw: FileNotFoundException

2015-02-24 Thread Batranut Bogdan
Also I must add that grepping the logs for a particular file I see this:  INFO [CompactionExecutor:19] 2015-02-24 10:44:35,618 CompactionTask.java (line 120) Compacting [SSTableReader(path='/data/ranks/positions/ranks-positions-jb-339-Data.db'), SSTableReader(path='/data/ranks/positions/ranks-po

FileNotFoundException

2015-02-24 Thread Batranut Bogdan
Hello all, One of my C* throws a big amount of exceptions like this: ERROR [ReadStage:792] 2015-02-24 10:43:54,183 CassandraDaemon.java (line 199) Exception in thread Thread[ReadStage:792,5,main]java.lang.RuntimeException: java.lang.RuntimeException: java.io.FileNotFoundException: /data/ranks/p