Question about read consistency level

2013-10-08 Thread graham sanderson
Apologies if this is an obvious question, I have looked but not seen too much (particularly about what exactly "latest version" means when there is no data on a node for a key - though I'd assume it has to be treated as "unknown" since you couldn't tell if the data had never been created or the

cassandra hadoop reducer writing to CQL3 - primary key - must it be text type?

2013-10-08 Thread John Lumby
I have been expermimenting with using hadoop for a map/reduce operation on cassandra, outputting to the CqlOutputFormat.class. I based my first program fairly closely on the famous WordCount example in examples/hadoop_cql3_word_count except  ---  I set my output colfamily to have a bigint primary

ArrayIndexOutOfBoundsException in StorageService.extractExpireTime

2013-10-08 Thread Viliam Holub
Hi, after upgrading our cluster from 1.1 to 1.2.10 I'm seeing this exception in system.log (on all nodes): ERROR [GossipStage:1] 2013-10-08 21:03:41,906 CassandraDaemon.java (line 185) Exception in thread Thread[GossipStage :1,5,main] java.lang.ArrayIndexOutOfBoundsException: 2 at org.

Re: Question about SizeTieredCompactionStrategy in C* 2.0: not all SSTables are being compacted

2013-10-08 Thread Sameer Farooqui
Hmm, good point. I'll test this out again and see the compaction behavior is as expected given the relative sizes of the SSTables. On Tue, Oct 8, 2013 at 3:06 PM, Tyler Hobbs wrote: > Well, 6 was created by the other sstables being compacted, correct? If > so, they were probably quite a bit

Using cassandra-cli with Client-server encryption

2013-10-08 Thread Vivek Mishra
Hi, I am trying to use cassandra-cli with client-server encryption enabled. But somehow getting handshake failure error(given below): org.apache.thrift.transport.TTransportException: javax.net.ssl.SSLHandshakeException: Received fatal alert: handshake_failure at org.apache.thrift.transport.TIO

Re: Question about SizeTieredCompactionStrategy in C* 2.0: not all SSTables are being compacted

2013-10-08 Thread Tyler Hobbs
Well, 6 was created by the other sstables being compacted, correct? If so, they were probably quite a bit smaller (~25% of the size). Once you have two more sstables of roughly that size, they should be compacted automatically. On Tue, Oct 8, 2013 at 2:01 PM, Sameer Farooqui wrote: > Thanks fo

Re: Any suggestions about running Cassandra on Windows servers for production use?

2013-10-08 Thread Robert Coli
On Mon, Oct 7, 2013 at 5:35 AM, Vassilis Bekiaris < bekiar...@iconplatforms.com> wrote: > we are planning a Cassandra 1.2 installation at a client site; the client > will run operations themselves and based on their IT team's experience they > are more inclined towards running Cassandra nodes on W

Re: Error during cleanup

2013-10-08 Thread Tyler Hobbs
On Tue, Oct 8, 2013 at 2:02 PM, Sameer Farooqui wrote: > If I issue another cleanup, can you give me the rough steps for how to get > the stacktrace? I'm hoping it will show up in Cassandra's system.log, but since it's triggered through JMX, it's possible that it will not. -- Tyler Hobbs Data

Re: Error during cleanup

2013-10-08 Thread Sameer Farooqui
No, but I may be able to get one for you if the issue is reproducible when I trigger another cleanup. I originally issued the cleanup on the node via OpsCenter Community Edition 3.2.2 If I issue another cleanup, can you give me the rough steps for how to get the stacktrace? On Tue, Oct 8, 2013

Re: Question about SizeTieredCompactionStrategy in C* 2.0: not all SSTables are being compacted

2013-10-08 Thread Sameer Farooqui
Thanks for the reply, Tyler. I thought that too.. that maybe the SSTables are mismatched in size... but upon closer inspection, that doesn't appear to be the case: -rw-r--r-- 1 cassandra cassandra 227 Oct 7 23:26 demodb-users-jb-1-Data.db -rw-r--r-- 1 cassandra cassandra 242 Oct 8 00:38 demodb

Re: Question about SizeTieredCompactionStrategy in C* 2.0: not all SSTables are being compacted

2013-10-08 Thread Tyler Hobbs
SizeTieredCompactionStrategy only compacts sstables that are a similar size (by default, they basically need to be within 50% of each other). Perhaps your first SSTable was very large or small compared to the others? On Mon, Oct 7, 2013 at 8:06 PM, Sameer Farooqui wrote: > Hi, > > I have a fres

Re: Error during cleanup

2013-10-08 Thread Tyler Hobbs
Do you have a complete stacktrace available? On Tue, Oct 8, 2013 at 2:08 AM, Sameer Farooqui wrote: > Hi, > > When running cleanup on a node with C* 2.0.1, I got the following error: > > cassandra01 - Error during cleanup: javax.management.MBeanException: > java.util.concurrent.ExecutionExceptio

Proper Use of PreparedStatements in DataStax driver

2013-10-08 Thread thn
Hello, I'm trying to determine the proper way to use PreparedStatements using the datastax CQL Java driver; so the API is Session session = ... PreparedStatement ps = session.prepare("INSERT INTO (column, ...) VALUES (?, ...)") BoundStatement bs = new BoundStatement(ps); //bind variables sess

TimedOutException in CqlRecordWriter

2013-10-08 Thread Renat Gilfanov
Hello, I run Hadoop jobs which read data from Cassandra 1.2.8 and write results back to another tables. One of my reduce tasks was killed 2 times by job tracker, because it wasn't responding for more than 10 minutes, the 3rd attempt was succesfull. The error message for killed reduce tasks is

Re: How to determine which node(s) an insert would go to in C* 2.0 with vnodes?

2013-10-08 Thread Kais Ahmed
hi, you can try : nodetool getendpoints- Print the end points that owns the key 2013/10/8 Christopher Wirt > In CQL there is a token() function you can use to find the result of your > partitioning schemes hash function for any value. > > ** ** > > e.g. select token(value) from colum

RE: How to determine which node(s) an insert would go to in C* 2.0 with vnodes?

2013-10-08 Thread Christopher Wirt
In CQL there is a token() function you can use to find the result of your partitioning schemes hash function for any value. e.g. select token(value) from column_family1 where partition_column = value; You then need to find out which nodes are responsible for that value using nodetool ring o

Bulk Loader in Cassandra :NullPointerException-sstable.AbstractSSTableSimpleWriter.addColumn

2013-10-08 Thread ashish sanadhya
I have created my key and column in cassandra like this CREATE KEYSPACE demou with placement_strategy = 'org.apache.cassandra.locator. SimpleStrategy' and strategy_options = [{replication_factor:1}]; CREATE COLUMN FAMILY users1 WITH comparator = UTF8Type AND key_valid

How to determine which node(s) an insert would go to in C* 2.0 with vnodes?

2013-10-08 Thread Sameer Farooqui
Hi, When using C* 2.0 in a large 100 node cluster with Murmer3Hash, vnodes and 256 tokens assigned to each node, is it possible to find out where a certain key is destined to go? If the keyspace defined has replication factor = 3, then a specific key like 'row-1' would be destined to go to 3 node

Error during cleanup

2013-10-08 Thread Sameer Farooqui
Hi, When running cleanup on a node with C* 2.0.1, I got the following error: cassandra01 - Error during cleanup: javax.management.MBeanException: java.util.concurrent.ExecutionException: java.lang.ClassCastException: org.apache.cassandra.io.sstable.SSTableReader$EmptyCompactionScanner cannot be c