Re: "Internal error processing get" in get after insert ttl

[Sylvain Lebresne]

You should not have anything special to do.
Could you check the cassandra logs and give us the stack trace of the error ?

--
Sylvain

On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
 wrote:
> Hello,
> I tried to use Column.Ttl property but I was not successful. My simple test:
> 1) insert column with ttl = 3
> 2) get column - all is ok
> 3) wait for 2 seconds
> 4) get column - all is ok
> 5) wait again for 2 seconds (so column should disappear)
> 6) get column - I got "Thrift.TApplicationException" of type 6 with message
> "Internal error processing get"
> Do I have to change some Cassandra configuration in order to get ttl
> working? Or am I doing anything in bad way?
> Thank you!
> Augi

Re: column expiration and rows in 0.7

[Alaa Zubaidi]

 Thanks..
but, in 0.7 every CF has its own "GCgraceSeconds" which is 
gc_grace_seconds, and I am setting gc_grace_seconds to 5 hours and the 
columns "ttl" to 4 hours, this means that after 5 hours the columns 
should be removed, and the keys are removed too, right?, however, I 
still see the keys and the size of the data is always growing?


Alaa

On 9/22/2010 8:00 PM, Stu Hood wrote:

Minor compactions will often be able to perform this garbage collection as well 
in 0.6.6 and 0.7.0 due to a great optimization implemented by Sylvain:

https://issues.apache.org/jira/browse/CASSANDRA-1074

-Original Message-
From: "Aaron Morton"
Sent: Wednesday, September 22, 2010 7:47pm
To: "user@cassandra.apache.org"
Subject: Re: column expiration and rows in 0.7

The data will only be physically deleted when a major compaction runs and the 
GCGraceSeconds has passed. You need to trigger the compaction using node tool.

http://wiki.apache.org/cassandra/DistributedDeletes

Aaron
On 23 Sep 2010, at 12:14, Alaa Zubaidi  wrote:


Hi,
I am expecting my data size to be around nGB. However, it keeps growing and 
growing.

I am setting the gc_grace_seconds for the CF to 5 hours, and I am also setting "ttl" for all 
columns on a row and expecting that these columns will be "deleted" after the ttl time, and will be 
"removed" after gc_grace_seonds, and I was told that the if ALL columns are deleted the whole row 
will be deleted as well? is this true or not?

Thanks,

Alaa Zubaidi

PDF Solutions, Inc.
333 West San Carlos Street, Suite 700
San Jose, CA 95110  USA
Tel: 408-283-5639 (or 408-280-7900 x5639)
fax: 408-938-6479
email: alaa.zuba...@pdf.com








--
Alaa Zubaidi
PDF Solutions, Inc.
333 West San Carlos Street, Suite 700
San Jose, CA 95110  USA
Tel: 408-283-5639 (or 408-280-7900 x5639)
fax: 408-938-6479
email: alaa.zuba...@pdf.com

Re: column expiration and rows in 0.7

[Sylvain Lebresne]

A few things:
  1- in your case, the expiring columns are gc-able 5 hours after the
column expires. So
  roughly 9 hours after the column insertion, not 5.
  2- columns are not necessarily removed after gc_grace_seconds
elapses exactly. They
  get removed by the first *major* compaction that is triggered
after that time elapses.
  And major compactions are not run automatically. You'll have to
trigger one through
  JMX (with nodetool for instance).
  3- for info, as Stu said, in recent trunk, some tombstone are deleted by minor
  compactions. But it requires some conditions that may not be met
in you case. So you
  need major compaction to be sure.

--
Sylvain

On Thu, Sep 23, 2010 at 9:56 AM, Alaa Zubaidi  wrote:
>  Thanks..
> but, in 0.7 every CF has its own "GCgraceSeconds" which is gc_grace_seconds,
> and I am setting gc_grace_seconds to 5 hours and the columns "ttl" to 4
> hours, this means that after 5 hours the columns should be removed, and the
> keys are removed too, right?, however, I still see the keys and the size of
> the data is always growing?
>
> Alaa
>
> On 9/22/2010 8:00 PM, Stu Hood wrote:
>>
>> Minor compactions will often be able to perform this garbage collection as
>> well in 0.6.6 and 0.7.0 due to a great optimization implemented by Sylvain:
>>
>> https://issues.apache.org/jira/browse/CASSANDRA-1074
>>
>> -Original Message-
>> From: "Aaron Morton"
>> Sent: Wednesday, September 22, 2010 7:47pm
>> To: "user@cassandra.apache.org"
>> Subject: Re: column expiration and rows in 0.7
>>
>> The data will only be physically deleted when a major compaction runs and
>> the GCGraceSeconds has passed. You need to trigger the compaction using node
>> tool.
>>
>> http://wiki.apache.org/cassandra/DistributedDeletes
>>
>> Aaron
>> On 23 Sep 2010, at 12:14, Alaa Zubaidi  wrote:
>>
>>> Hi,
>>> I am expecting my data size to be around nGB. However, it keeps growing
>>> and growing.
>>>
>>> I am setting the gc_grace_seconds for the CF to 5 hours, and I am also
>>> setting "ttl" for all columns on a row and expecting that these columns will
>>> be "deleted" after the ttl time, and will be "removed" after
>>> gc_grace_seonds, and I was told that the if ALL columns are deleted the
>>> whole row will be deleted as well? is this true or not?
>>>
>>> Thanks,
>>>
>>> Alaa Zubaidi
>>>
>>> PDF Solutions, Inc.
>>> 333 West San Carlos Street, Suite 700
>>> San Jose, CA 95110  USA
>>> Tel: 408-283-5639 (or 408-280-7900 x5639)
>>> fax: 408-938-6479
>>> email: alaa.zuba...@pdf.com
>>>
>>>
>>
>>
>>
>
> --
> Alaa Zubaidi
> PDF Solutions, Inc.
> 333 West San Carlos Street, Suite 700
> San Jose, CA 95110  USA
> Tel: 408-283-5639 (or 408-280-7900 x5639)
> fax: 408-938-6479
> email: alaa.zuba...@pdf.com
>
>
>

Re: "Internal error processing get" in get after insert ttl -

[vineet daniel]

I got similar error but while inserting I am using 07 Beta 1 and l found the
following in the logs :

ERROR 13:59:44,555 Internal error processing insert
java.lang.AssertionError: invalid response count 1
at
org.apache.cassandra.service.WriteResponseHandler.determineBlockFor(WriteResponseHandler.java:87)
at
org.apache.cassandra.service.WriteResponseHandler.(WriteResponseHandler.java:47)
at
org.apache.cassandra.locator.AbstractReplicationStrategy.getWriteResponseHandler(AbstractReplicationStrategy.java:113)
at
org.apache.cassandra.service.StorageProxy.mutateBlocking(StorageProxy.java:198)
at
org.apache.cassandra.thrift.CassandraServer.doInsert(CassandraServer.java:474)
at
org.apache.cassandra.thrift.CassandraServer.insert(CassandraServer.java:390)
at
org.apache.cassandra.thrift.Cassandra$Processor$insert.process(Cassandra.java:2896)
at
org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2499)
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:636)


Regards
Vineet Daniel
Cell  : +918106217121
Websites :
Blog    |
Linkedin
|  Twitter 





On Thu, Sep 23, 2010 at 12:48 PM, Sylvain Lebresne wrote:

> You should not have anything special to do.
> Could you check the cassandra logs and give us the stack trace of the error
> ?
>
> --
> Sylvain
>
> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>  wrote:
> > Hello,
> > I tried to use Column.Ttl property but I was not successful. My simple
> test:
> > 1) insert column with ttl = 3
> > 2) get column - all is ok
> > 3) wait for 2 seconds
> > 4) get column - all is ok
> > 5) wait again for 2 seconds (so column should disappear)
> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
> message
> > "Internal error processing get"
> > Do I have to change some Cassandra configuration in order to get ttl
> > working? Or am I doing anything in bad way?
> > Thank you!
> > Augi
>

Throughput performance problem

[Martin Hentschel]

When inserting rows to Cassandra, we have noticed an odd performance behavior.  
When we insert rows with increasing row keys (0,1,2,...) we get a throughput 
that is 10% higher than when we insert rows with random row keys (in the range 
of 0 to 1'000'000).

This is strange because we use the RandomPartitioner.

Do you have any ideas?

Thanks,

Martin

Re: "Internal error processing get" in get after insert ttl -

[vineet daniel]

Hi

I was using 'access_logs' as column family name changed it to Accesslogs and
it worked. May be cassandra doesn't like underscores and small letters.

Regards
Vineet Daniel
Cell  : +918106217121
Websites :
Blog    |
Linkedin
|  Twitter 





On Thu, Sep 23, 2010 at 2:06 PM, vineet daniel wrote:

> I got similar error but while inserting I am using 07 Beta 1 and l found
> the following in the logs :
>
> ERROR 13:59:44,555 Internal error processing insert
> java.lang.AssertionError: invalid response count 1
> at
> org.apache.cassandra.service.WriteResponseHandler.determineBlockFor(WriteResponseHandler.java:87)
> at
> org.apache.cassandra.service.WriteResponseHandler.(WriteResponseHandler.java:47)
> at
> org.apache.cassandra.locator.AbstractReplicationStrategy.getWriteResponseHandler(AbstractReplicationStrategy.java:113)
> at
> org.apache.cassandra.service.StorageProxy.mutateBlocking(StorageProxy.java:198)
> at
> org.apache.cassandra.thrift.CassandraServer.doInsert(CassandraServer.java:474)
> at
> org.apache.cassandra.thrift.CassandraServer.insert(CassandraServer.java:390)
> at
> org.apache.cassandra.thrift.Cassandra$Processor$insert.process(Cassandra.java:2896)
> at
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2499)
> at
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
> at java.lang.Thread.run(Thread.java:636)
>
>
> Regards
> Vineet Daniel
> Cell  : +918106217121
> Websites :
> Blog    |   
> Linkedin
> |  Twitter 
>
>
>
>
>
> On Thu, Sep 23, 2010 at 12:48 PM, Sylvain Lebresne wrote:
>
>> You should not have anything special to do.
>> Could you check the cassandra logs and give us the stack trace of the
>> error ?
>>
>> --
>> Sylvain
>>
>> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>>  wrote:
>> > Hello,
>> > I tried to use Column.Ttl property but I was not successful. My simple
>> test:
>> > 1) insert column with ttl = 3
>> > 2) get column - all is ok
>> > 3) wait for 2 seconds
>> > 4) get column - all is ok
>> > 5) wait again for 2 seconds (so column should disappear)
>> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
>> message
>> > "Internal error processing get"
>> > Do I have to change some Cassandra configuration in order to get ttl
>> > working? Or am I doing anything in bad way?
>> > Thank you!
>> > Augi
>>
>
>

Re: "Internal error processing get" in get after insert ttl -

[Michal Augustýn]

I don't have underscores in column families names...
Btw. I'm using yesterday's night build.

Augi

2010/9/23 vineet daniel 

> Hi
>
> I was using 'access_logs' as column family name changed it to Accesslogs
> and it worked. May be cassandra doesn't like underscores and small letters.
>
>
> Regards
> Vineet Daniel
> Cell  : +918106217121
> Websites :
> Blog    |   
> Linkedin
> |  Twitter 
>
>
>
>
>
> On Thu, Sep 23, 2010 at 2:06 PM, vineet daniel wrote:
>
>> I got similar error but while inserting I am using 07 Beta 1 and l found
>> the following in the logs :
>>
>> ERROR 13:59:44,555 Internal error processing insert
>> java.lang.AssertionError: invalid response count 1
>> at
>> org.apache.cassandra.service.WriteResponseHandler.determineBlockFor(WriteResponseHandler.java:87)
>> at
>> org.apache.cassandra.service.WriteResponseHandler.(WriteResponseHandler.java:47)
>> at
>> org.apache.cassandra.locator.AbstractReplicationStrategy.getWriteResponseHandler(AbstractReplicationStrategy.java:113)
>> at
>> org.apache.cassandra.service.StorageProxy.mutateBlocking(StorageProxy.java:198)
>> at
>> org.apache.cassandra.thrift.CassandraServer.doInsert(CassandraServer.java:474)
>> at
>> org.apache.cassandra.thrift.CassandraServer.insert(CassandraServer.java:390)
>> at
>> org.apache.cassandra.thrift.Cassandra$Processor$insert.process(Cassandra.java:2896)
>> at
>> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2499)
>> at
>> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
>> at
>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>> at
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>> at java.lang.Thread.run(Thread.java:636)
>>
>>
>> Regards
>> Vineet Daniel
>> Cell  : +918106217121
>> Websites :
>> Blog    |   
>> Linkedin
>> |  Twitter 
>>
>>
>>
>>
>>
>> On Thu, Sep 23, 2010 at 12:48 PM, Sylvain Lebresne wrote:
>>
>>> You should not have anything special to do.
>>> Could you check the cassandra logs and give us the stack trace of the
>>> error ?
>>>
>>> --
>>> Sylvain
>>>
>>> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>>>  wrote:
>>> > Hello,
>>> > I tried to use Column.Ttl property but I was not successful. My simple
>>> test:
>>> > 1) insert column with ttl = 3
>>> > 2) get column - all is ok
>>> > 3) wait for 2 seconds
>>> > 4) get column - all is ok
>>> > 5) wait again for 2 seconds (so column should disappear)
>>> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
>>> message
>>> > "Internal error processing get"
>>> > Do I have to change some Cassandra configuration in order to get ttl
>>> > working? Or am I doing anything in bad way?
>>> > Thank you!
>>> > Augi
>>>
>>
>>
>

Re: "Internal error processing get" in get after insert ttl

[Michal Augustýn]

Unfortunately, I'm running Cassandra on Windows platform and the logging
doesn't work; I'm not able to configure them properly respectively.
I always get "log4j:WARN No appenders could be found for logger
(org.apache.cassandra.utils.CLibrary)." after Cassandra starts. I tried to
copy "log4j-server.properties" to Cassandra home directory, to /bin
directory, to /lib directory, but the file still cannot be found :(
I'm using Cassandra.bat file to run them...

Augi


2010/9/23 Sylvain Lebresne 

> You should not have anything special to do.
> Could you check the cassandra logs and give us the stack trace of the error
> ?
>
> --
> Sylvain
>
> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>  wrote:
> > Hello,
> > I tried to use Column.Ttl property but I was not successful. My simple
> test:
> > 1) insert column with ttl = 3
> > 2) get column - all is ok
> > 3) wait for 2 seconds
> > 4) get column - all is ok
> > 5) wait again for 2 seconds (so column should disappear)
> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
> message
> > "Internal error processing get"
> > Do I have to change some Cassandra configuration in order to get ttl
> > working? Or am I doing anything in bad way?
> > Thank you!
> > Augi
>

Re: "Internal error processing get" in get after insert ttl -

[Jonathan Ellis]

this probably means you have a nonsense replicationfactor on that
keyspace. r1000404 adds that information to the assert in trunk.

On Thu, Sep 23, 2010 at 3:36 AM, vineet daniel  wrote:
> I got similar error but while inserting I am using 07 Beta 1 and l found the
> following in the logs :
>
> ERROR 13:59:44,555 Internal error processing insert
> java.lang.AssertionError: invalid response count 1
>     at
> org.apache.cassandra.service.WriteResponseHandler.determineBlockFor(WriteResponseHandler.java:87)
>     at
> org.apache.cassandra.service.WriteResponseHandler.(WriteResponseHandler.java:47)
>     at
> org.apache.cassandra.locator.AbstractReplicationStrategy.getWriteResponseHandler(AbstractReplicationStrategy.java:113)
>     at
> org.apache.cassandra.service.StorageProxy.mutateBlocking(StorageProxy.java:198)
>     at
> org.apache.cassandra.thrift.CassandraServer.doInsert(CassandraServer.java:474)
>     at
> org.apache.cassandra.thrift.CassandraServer.insert(CassandraServer.java:390)
>     at
> org.apache.cassandra.thrift.Cassandra$Processor$insert.process(Cassandra.java:2896)
>     at
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2499)
>     at
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
>     at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>     at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>     at java.lang.Thread.run(Thread.java:636)
>
>
> Regards
> Vineet Daniel
> Cell  : +918106217121
> Websites :
> Blog   |   Linkedin  |  Twitter
>
>
>
>
> On Thu, Sep 23, 2010 at 12:48 PM, Sylvain Lebresne 
> wrote:
>>
>> You should not have anything special to do.
>> Could you check the cassandra logs and give us the stack trace of the
>> error ?
>>
>> --
>> Sylvain
>>
>> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>>  wrote:
>> > Hello,
>> > I tried to use Column.Ttl property but I was not successful. My simple
>> > test:
>> > 1) insert column with ttl = 3
>> > 2) get column - all is ok
>> > 3) wait for 2 seconds
>> > 4) get column - all is ok
>> > 5) wait again for 2 seconds (so column should disappear)
>> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
>> > message
>> > "Internal error processing get"
>> > Do I have to change some Cassandra configuration in order to get ttl
>> > working? Or am I doing anything in bad way?
>> > Thank you!
>> > Augi
>
>



-- 
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com

Re: "Internal error processing get" in get after insert ttl

[Jonathan Ellis]

cassandra.bat is looking for a file named log4j.properties on the classpath.

On Thu, Sep 23, 2010 at 5:52 AM, Michal Augustýn
 wrote:
> Unfortunately, I'm running Cassandra on Windows platform and the logging
> doesn't work; I'm not able to configure them properly respectively.
> I always get "log4j:WARN No appenders could be found for logger
> (org.apache.cassandra.utils.CLibrary)." after Cassandra starts. I tried to
> copy "log4j-server.properties" to Cassandra home directory, to /bin
> directory, to /lib directory, but the file still cannot be found :(
> I'm using Cassandra.bat file to run them...
> Augi
>
> 2010/9/23 Sylvain Lebresne 
>>
>> You should not have anything special to do.
>> Could you check the cassandra logs and give us the stack trace of the
>> error ?
>>
>> --
>> Sylvain
>>
>> On Thu, Sep 23, 2010 at 8:36 AM, Michal Augustýn
>>  wrote:
>> > Hello,
>> > I tried to use Column.Ttl property but I was not successful. My simple
>> > test:
>> > 1) insert column with ttl = 3
>> > 2) get column - all is ok
>> > 3) wait for 2 seconds
>> > 4) get column - all is ok
>> > 5) wait again for 2 seconds (so column should disappear)
>> > 6) get column - I got "Thrift.TApplicationException" of type 6 with
>> > message
>> > "Internal error processing get"
>> > Do I have to change some Cassandra configuration in order to get ttl
>> > working? Or am I doing anything in bad way?
>> > Thank you!
>> > Augi
>
>



-- 
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com

Re: "Internal error processing get" in get after insert ttl

[Michal Augustýn]

Ah, I didn't know that, thank you!
Here is the trace:

ERROR 13:25:59,418 Internal error processing get
java.lang.RuntimeException: java.util.concurrent.ExecutionException:
java.lang.IllegalStateException: column is not marked for delete
at
org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:275)
at
org.apache.cassandra.service.StorageProxy.readProtocol(StorageProxy.java:218)
at
org.apache.cassandra.thrift.CassandraServer.readColumnFamily(CassandraServer.java:115)
at
org.apache.cassandra.thrift.CassandraServer.get(CassandraServer.java:314)
at
org.apache.cassandra.thrift.Cassandra$Processor$get.process(Cassandra.java:2747)
at
org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2647)
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.util.concurrent.ExecutionException:
java.lang.IllegalStateException: column is not marked for delete
at
java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at
org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:271)
... 9 more
Caused by: java.lang.IllegalStateException: column is not marked for delete
at
org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
at
org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
at
org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
at
org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
at
org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
at
org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
at
org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
at org.apache.cassandra.db.Table.getRow(Table.java:322)
at
org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
at
org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
... 3 more
ERROR 13:25:59,418 Fatal exception in thread Thread[READ_STAGE:3,5,main]
java.lang.IllegalStateException: column is not marked for delete
at
org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
at
org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
at
org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
at
org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
at
org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
at
org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
at
org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
at org.apache.cassandra.db.Table.getRow(Table.java:322)
at
org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
at
org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)

Augi

2010/9/23 Jonathan Ellis 

> cassandra.bat is looking for a file named log4j.properties on the
> classpath.
>
> On Thu, Sep 23, 2010 at 5:52 AM, Michal Augustýn
>  wrote:
> > Unfortunately, I'm running Cassandra on Windows platform and the logging
> > doesn't work; I'm not able to configure them properly respectively.
> > I always get "log4j:WARN No appenders could be found for logger
> > (org.apache.cassandra.utils.CLibrary)." after Cassandra starts. I tried
> to
> > copy "log4j-server.properties" to Cassandra home directory, to /bin
> > directory, to /lib directory, but the file still cannot be found :(
> > I'm using Cassandra.bat file to run them...
> > Augi
> >
> > 2010/9/23 Sylvain Lebresne 
> >>
> >> You should not have anything special to do.
> >> Could you check the cassandra logs and give us the stack trace of the
> >> error ?
> >>
> >> --
> >> Sylvain

Re: "Internal error processing get" in get after insert ttl

[Sylvain Lebresne]

Oups, that would be a bug.
Would you mind grabbing the patch attached to
https://issues.apache.org/jira/browse/CASSANDRA-1539 and check that is
does fix the problem ?

--
Sylvain

On Thu, Sep 23, 2010 at 1:28 PM, Michal Augustýn
 wrote:
> Ah, I didn't know that, thank you!
> Here is the trace:
> ERROR 13:25:59,418 Internal error processing get
> java.lang.RuntimeException: java.util.concurrent.ExecutionException:
> java.lang.IllegalStateException: column is not marked for delete
>         at
> org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:275)
>         at
> org.apache.cassandra.service.StorageProxy.readProtocol(StorageProxy.java:218)
>         at
> org.apache.cassandra.thrift.CassandraServer.readColumnFamily(CassandraServer.java:115)
>         at
> org.apache.cassandra.thrift.CassandraServer.get(CassandraServer.java:314)
>         at
> org.apache.cassandra.thrift.Cassandra$Processor$get.process(Cassandra.java:2747)
>         at
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2647)
>         at
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.ExecutionException:
> java.lang.IllegalStateException: column is not marked for delete
>         at
> java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
>         at java.util.concurrent.FutureTask.get(FutureTask.java:83)
>         at
> org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:271)
>         ... 9 more
> Caused by: java.lang.IllegalStateException: column is not marked for delete
>         at
> org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
>         at
> org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
>         at
> org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
>         at
> org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
>         at org.apache.cassandra.db.Table.getRow(Table.java:322)
>         at
> org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
>         at
> org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
>         at
> java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>         ... 3 more
> ERROR 13:25:59,418 Fatal exception in thread Thread[READ_STAGE:3,5,main]
> java.lang.IllegalStateException: column is not marked for delete
>         at
> org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
>         at
> org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
>         at
> org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
>         at
> org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
>         at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
>         at org.apache.cassandra.db.Table.getRow(Table.java:322)
>         at
> org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
>         at
> org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
>         at
> java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:619)
> Augi
> 2010/9/23 Jonathan Ellis 
>>
>> cassandra.bat is looking for a file named log4j.properties on the
>> classpath.
>>
>> On Thu, Sep 23, 2010 at 5:52 AM, Michal Augustýn
>>  wrote:
>> > Unfortunately, I'm running Cassandra on Windows platform and the logging
>> > doesn't work; I'm not able to configure them properly respectively.
>> > I always get "log4j:WARN No appenders could be found for logger
>> > (org.apache.cassandra.utils.CLibrary)." after Cassandra starts

Re: "Internal error processing get" in get after insert ttl

[Michal Augustýn]

Thank you very much! This solved my problem. Columns are really deleted and
there is no warn/error in log.

Augi

2010/9/23 Sylvain Lebresne 

> Oups, that would be a bug.
> Would you mind grabbing the patch attached to
> https://issues.apache.org/jira/browse/CASSANDRA-1539 and check that is
> does fix the problem ?
>
> --
> Sylvain
>
> On Thu, Sep 23, 2010 at 1:28 PM, Michal Augustýn
>  wrote:
> > Ah, I didn't know that, thank you!
> > Here is the trace:
> > ERROR 13:25:59,418 Internal error processing get
> > java.lang.RuntimeException: java.util.concurrent.ExecutionException:
> > java.lang.IllegalStateException: column is not marked for delete
> > at
> > org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:275)
> > at
> >
> org.apache.cassandra.service.StorageProxy.readProtocol(StorageProxy.java:218)
> > at
> >
> org.apache.cassandra.thrift.CassandraServer.readColumnFamily(CassandraServer.java:115)
> > at
> > org.apache.cassandra.thrift.CassandraServer.get(CassandraServer.java:314)
> > at
> >
> org.apache.cassandra.thrift.Cassandra$Processor$get.process(Cassandra.java:2747)
> > at
> >
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2647)
> > at
> >
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
> > at
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> > at
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> > at java.lang.Thread.run(Thread.java:619)
> > Caused by: java.util.concurrent.ExecutionException:
> > java.lang.IllegalStateException: column is not marked for delete
> > at
> > java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
> > at java.util.concurrent.FutureTask.get(FutureTask.java:83)
> > at
> > org.apache.cassandra.service.StorageProxy.weakRead(StorageProxy.java:271)
> > ... 9 more
> > Caused by: java.lang.IllegalStateException: column is not marked for
> delete
> > at
> > org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
> > at
> >
> org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
> > at
> >
> org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
> > at
> >
> org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
> > at org.apache.cassandra.db.Table.getRow(Table.java:322)
> > at
> >
> org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
> > at
> >
> org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
> > at
> > java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> > at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> > ... 3 more
> > ERROR 13:25:59,418 Fatal exception in thread Thread[READ_STAGE:3,5,main]
> > java.lang.IllegalStateException: column is not marked for delete
> > at
> > org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
> > at
> >
> org.apache.cassandra.db.filter.QueryFilter.isRelevant(QueryFilter.java:151)
> > at
> >
> org.apache.cassandra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:81)
> > at
> >
> org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilter.java:137)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1025)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:910)
> > at
> >
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:880)
> > at org.apache.cassandra.db.Table.getRow(Table.java:322)
> > at
> >
> org.apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand.java:59)
> > at
> >
> org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:734)
> > at
> > java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> > at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> > at
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> > at
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> > at java.lang.Thread.run(Thread.java:619)
> > Augi
> > 2010/9/23 Jonathan Ellis 
> >>
> >> cassandra.bat is looking for a file named 

Re: Thrift gen problem with cassandra.thrift

[Tyler Hobbs]

Is it possible that you are somehow using the 0.7 generated cassandra
module, perhaps from some previous installation of a client library?  In
0.7, insert takes only 5 arguments.

Also, is there any particular reason that you are using raw Thrift and not a
high level client like pycassa, telephus, etc?

- Tyler


On Wed, Sep 22, 2010 at 9:32 PM, Shashank Tiwari  wrote:

> Jeremy and Aaron,
> Thanks for your help.
>
> I had already installed Thrift on my Snow Leopard so I thought running  
> *thrift
> -gen cassandra.thrift* file would work. However as the wiki suggests it
> appears only a specific version of Thrift work with a particular Cassandra
> version. So I checked out the matching version of Thrift. Even after getting
> the exact version of Thrift though, getting it to work wasn't straight
> forward and in fact its still throwing errors.
>
> Aaron's suggestions of using the ant task (*ant gen-thrift-py*) seemed
> much smoother but then that task does not generate the python thrift module,
> it only generates the cassandra module.
>
> So I used a mix and match of both methods and finally have both the thrift
> and the cassandra modules. However, it now seems there is a mismatch in the
> API. I ran the python example from
> http://wiki.apache.org/cassandra/ThriftExamples#Python and ended up with
> the following errors:
>
> Traceback (most recent call last):
>   File "cassandra_client.py", line 52, in 
> main()
>   File "cassandra_client.py", line 35, in main
> ConsistencyLevel.ZERO)
> TypeError: insert() takes exactly 5 arguments (7 given)
>
> --
> Line 35 of cassandra_client.py is the same as line 35 of the python example
> on the Cassandra wiki Thrift Examples page. Its the line in bold in the code
> snippet below:
>
> try:
> transport.open()
> #Insert the data into Keyspace 1
> *client.insert(keyspace,*
> *  key,*
> *  column_path,*
> *  value,*
> *  timestamp,*
> *  ConsistencyLevel.ZERO)*
> #Query for data
> column_parent = ColumnParent(column_family="Standard1")
> slice_range = SliceRange(start="", finish="")
> predicate = SlicePredicate(slice_range=slice_range)
> result = client.get_slice(keyspace,
>   key,
>   column_parent,
>   predicate,
>   ConsistencyLevel.ONE)
> pp.pprint(result)
> except Thrift.TException, tx:
> print 'Thrift: %s' % tx.message
> finally:
>
> Can somebody please help and make sense of this. Isn't there a more simple
> and straightforward way getting Thrift to work with Cassandra? If not, why
> not?
>
> Thanks, Shashank
>
>
> On Wed, Sep 22, 2010 at 1:16 PM, Aaron Morton wrote:
>
>> I normally get the source download, then run ant gen-thrift-py
>>
>> Is there a reason you want to build it manually?
>>
>> Aaron
>>
>>
>> On 22 Sep, 2010,at 07:35 PM, Shashank Tiwari  wrote:
>>
>> I installed thrift successfully on Snow Leaopard. However, when I run
>> *thrift -gen java interface/cassandra.thrift* with Cassandra 0.6.5, I get
>> an error which reads as follows:
>> apache-cassandra-0.6.5/interface/cassandra.thrift:303] error:
>> identifier ONE is unqualified!
>> Line 303 of cassandra.thrift is highlighted in the text below:
>>
>> 296   /**
>> 297 Get the Column or SuperColumn at the given column_path. If no
>> value is present, NotFoundException is thrown. (This is
>> 298 the only method that can throw an exception under non-failure
>> conditions)
>> 299*/
>> 300   ColumnOrSuperColumn get(1:required string keyspace,
>> 301   2:required string key,
>> 302   3:required ColumnPath column_path,
>> *303   4:required ConsistencyLevel
>> consistency_level=ONE)*
>> 304   throws (1:InvalidRequestException ire,
>> 2:NotFoundException nfe, 3:UnavailableException ue, 4:TimedOutException
>> te),
>> 305
>>
>> Could somebody please help resolve this problem and also explain what's
>> going on here.
>>
>> Thanks, Shashank
>>
>>
>

NullPointerException in TCP Selector Manager [Cassandra 0.5.1]

[Adam Holmberg]

Hello,

I've been working with Cassandra for some time and get this error
intermittently:

ERROR [TCP Selector Manager] 2010-09-23 08:42:18,138 service.CassandraDaemon
Fatal exception in thread Thread[TCP Selector Manager,5,main]
java.lang.NullPointerException
at
org.apache.cassandra.net.TcpConnection.resumeStreaming(TcpConnection.java:268)
at
org.apache.cassandra.net.TcpConnection.connect(TcpConnection.java:354)
at
org.apache.cassandra.net.SelectorManager.doProcess(SelectorManager.java:143)
at
org.apache.cassandra.net.SelectorManager.run(SelectorManager.java:2107)

Unfortunately when this happens the socket is left open so clients connect,
but are never serviced. When this happens I am forced to restart the node.

We're running version 0.5.1. I know there are much newer versions, but we
have been frozen on this for various reasons.

I am wondering if this is/was a known issue with this version, or if I am
doing something wrong. My searches thus far have yielded nothing on the
matter.

Any insights would be appreciated.

Regards,
Adam

Re: Thrift gen problem with cassandra.thrift

[Shashank Tiwari]

I finally grabbed Cassandra off the trunk to make things work so I guess it
is 0.7. If I start the same server and connect to it, should things work? I
am happy using pycassa or telephus but I had Thrift installed for things
beyond Cassandra (for example for Hypertable) and I was hoping that
installation would work with multiple products that use Thrift. Now I know
it doesn't.

Thanks, Shashank

On Thu, Sep 23, 2010 at 10:17 AM, Tyler Hobbs  wrote:

> Is it possible that you are somehow using the 0.7 generated cassandra
> module, perhaps from some previous installation of a client library?  In
> 0.7, insert takes only 5 arguments.
>
> Also, is there any particular reason that you are using raw Thrift and not
> a high level client like pycassa, telephus, etc?
>
> - Tyler
>
>
>
> On Wed, Sep 22, 2010 at 9:32 PM, Shashank Tiwari wrote:
>
>> Jeremy and Aaron,
>> Thanks for your help.
>>
>> I had already installed Thrift on my Snow Leopard so I thought running  
>> *thrift
>> -gen cassandra.thrift* file would work. However as the wiki suggests it
>> appears only a specific version of Thrift work with a particular Cassandra
>> version. So I checked out the matching version of Thrift. Even after getting
>> the exact version of Thrift though, getting it to work wasn't straight
>> forward and in fact its still throwing errors.
>>
>> Aaron's suggestions of using the ant task (*ant gen-thrift-py*) seemed
>> much smoother but then that task does not generate the python thrift module,
>> it only generates the cassandra module.
>>
>> So I used a mix and match of both methods and finally have both the thrift
>> and the cassandra modules. However, it now seems there is a mismatch in the
>> API. I ran the python example from
>> http://wiki.apache.org/cassandra/ThriftExamples#Python and ended up with
>> the following errors:
>>
>> Traceback (most recent call last):
>>   File "cassandra_client.py", line 52, in 
>> main()
>>   File "cassandra_client.py", line 35, in main
>> ConsistencyLevel.ZERO)
>> TypeError: insert() takes exactly 5 arguments (7 given)
>>
>> --
>> Line 35 of cassandra_client.py is the same as line 35 of the python
>> example on the Cassandra wiki Thrift Examples page. Its the line in bold in
>> the code snippet below:
>>
>> try:
>> transport.open()
>> #Insert the data into Keyspace 1
>> *client.insert(keyspace,*
>> *  key,*
>> *  column_path,*
>> *  value,*
>> *  timestamp,*
>> *  ConsistencyLevel.ZERO)*
>> #Query for data
>> column_parent = ColumnParent(column_family="Standard1")
>> slice_range = SliceRange(start="", finish="")
>> predicate = SlicePredicate(slice_range=slice_range)
>> result = client.get_slice(keyspace,
>>   key,
>>   column_parent,
>>   predicate,
>>   ConsistencyLevel.ONE)
>> pp.pprint(result)
>> except Thrift.TException, tx:
>> print 'Thrift: %s' % tx.message
>> finally:
>>
>> Can somebody please help and make sense of this. Isn't there a more simple
>> and straightforward way getting Thrift to work with Cassandra? If not, why
>> not?
>>
>> Thanks, Shashank
>>
>>
>> On Wed, Sep 22, 2010 at 1:16 PM, Aaron Morton wrote:
>>
>>> I normally get the source download, then run ant gen-thrift-py
>>>
>>> Is there a reason you want to build it manually?
>>>
>>> Aaron
>>>
>>>
>>> On 22 Sep, 2010,at 07:35 PM, Shashank Tiwari  wrote:
>>>
>>> I installed thrift successfully on Snow Leaopard. However, when I run
>>> *thrift -gen java interface/cassandra.thrift* with Cassandra 0.6.5, I
>>> get an error which reads as follows:
>>> apache-cassandra-0.6.5/interface/cassandra.thrift:303] error:
>>> identifier ONE is unqualified!
>>> Line 303 of cassandra.thrift is highlighted in the text below:
>>>
>>> 296   /**
>>> 297 Get the Column or SuperColumn at the given column_path. If no
>>> value is present, NotFoundException is thrown. (This is
>>> 298 the only method that can throw an exception under non-failure
>>> conditions)
>>> 299*/
>>> 300   ColumnOrSuperColumn get(1:required string keyspace,
>>> 301   2:required string key,
>>> 302   3:required ColumnPath column_path,
>>> *303   4:required ConsistencyLevel
>>> consistency_level=ONE)*
>>> 304   throws (1:InvalidRequestException ire,
>>> 2:NotFoundException nfe, 3:UnavailableException ue, 4:TimedOutException
>>> te),
>>> 305
>>>
>>> Could somebody please help resolve this problem and also explain what's
>>> going on here.
>>>
>>> Thanks, Shashank
>>>
>>>
>>
>

Re: NullPointerException in TCP Selector Manager [Cassandra 0.5.1]

[Jonathan Ellis]

Yes, that is a problem with 0.5.1.  Unfortunately we are not planning
any more releases to 0.5.

On Thu, Sep 23, 2010 at 1:18 PM, Adam Holmberg
 wrote:
> Hello,
>
> I've been working with Cassandra for some time and get this error
> intermittently:
>
> ERROR [TCP Selector Manager] 2010-09-23 08:42:18,138 service.CassandraDaemon
> Fatal exception in thread Thread[TCP Selector Manager,5,main]
> java.lang.NullPointerException
>     at
> org.apache.cassandra.net.TcpConnection.resumeStreaming(TcpConnection.java:268)
>     at
> org.apache.cassandra.net.TcpConnection.connect(TcpConnection.java:354)
>     at
> org.apache.cassandra.net.SelectorManager.doProcess(SelectorManager.java:143)
>     at
> org.apache.cassandra.net.SelectorManager.run(SelectorManager.java:2107)
>
> Unfortunately when this happens the socket is left open so clients connect,
> but are never serviced. When this happens I am forced to restart the node.
>
> We're running version 0.5.1. I know there are much newer versions, but we
> have been frozen on this for various reasons.
>
> I am wondering if this is/was a known issue with this version, or if I am
> doing something wrong. My searches thus far have yielded nothing on the
> matter.
>
> Any insights would be appreciated.
>
> Regards,
> Adam
>



-- 
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com

Re: NullPointerException in TCP Selector Manager [Cassandra 0.5.1]

[Adam Holmberg]

Thanks, Jonathan.

Does any know if this is documented anywhere? I didn't turn up anything
searching JIRA or the web.

Adam

On Thu, Sep 23, 2010 at 12:58 PM, Jonathan Ellis  wrote:

> Yes, that is a problem with 0.5.1.  Unfortunately we are not planning
> any more releases to 0.5.
>
> On Thu, Sep 23, 2010 at 1:18 PM, Adam Holmberg
>  wrote:
> > Hello,
> >
> > I've been working with Cassandra for some time and get this error
> > intermittently:
> >
> > ERROR [TCP Selector Manager] 2010-09-23 08:42:18,138
> service.CassandraDaemon
> > Fatal exception in thread Thread[TCP Selector Manager,5,main]
> > java.lang.NullPointerException
> > at
> >
> org.apache.cassandra.net.TcpConnection.resumeStreaming(TcpConnection.java:268)
> > at
> > org.apache.cassandra.net.TcpConnection.connect(TcpConnection.java:354)
> > at
> >
> org.apache.cassandra.net.SelectorManager.doProcess(SelectorManager.java:143)
> > at
> > org.apache.cassandra.net.SelectorManager.run(SelectorManager.java:2107)
> >
> > Unfortunately when this happens the socket is left open so clients
> connect,
> > but are never serviced. When this happens I am forced to restart the
> node.
> >
> > We're running version 0.5.1. I know there are much newer versions, but we
> > have been frozen on this for various reasons.
> >
> > I am wondering if this is/was a known issue with this version, or if I am
> > doing something wrong. My searches thus far have yielded nothing on the
> > matter.
> >
> > Any insights would be appreciated.
> >
> > Regards,
> > Adam
> >
>
>
>
> --
> Jonathan Ellis
> Project Chair, Apache Cassandra
> co-founder of Riptano, the source for professional Cassandra support
> http://riptano.com
>