Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 991 invoked from network); 23 Sep 2010 11:29:14 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 23 Sep 2010 11:29:14 -0000 Received: (qmail 73166 invoked by uid 500); 23 Sep 2010 11:29:12 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 72287 invoked by uid 500); 23 Sep 2010 11:29:09 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 72278 invoked by uid 99); 23 Sep 2010 11:29:08 -0000 Received: from Unknown (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Sep 2010 11:29:08 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of augustyn.michal@gmail.com designates 209.85.216.44 as permitted sender) Received: from [209.85.216.44] (HELO mail-qw0-f44.google.com) (209.85.216.44) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Sep 2010 11:28:47 +0000 Received: by qwc9 with SMTP id 9so1254241qwc.31 for ; Thu, 23 Sep 2010 04:28:26 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:received:in-reply-to :references:date:message-id:subject:from:to:content-type; bh=dU4+C1IedpjAge1Mf9PwNBC0L/EE1aX6ZMTgOsepeR0=; b=uFUNxHLEExycO9LNJLqN1jZko1vKYTwAxLKJ+CQVQSDHAdltk3chdxGx5Eb2guPJZx j53/cFOxe4hL7prI/qM7VSUnVQZeGMR89X8frFWvzMsoTwRJb5BQnJCIO8QsOdHyaqFg Adu4Bkm0zEMxxgyM53q0wlkjgg+OyWNY5MhgI= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=i+uUxpf9Jed4drE1ViFnvxm0zngRE6SA5btU2M+w7O6yRq9587y7rRCFDH/VD8tbD2 cNiLDPM19I1Co8WhI4WLgG4zPIJgE9ENnvRpVVojOpvWjxUsDJtjsIkU9doIG/Si0fz6 yt46uYMhWbeVSFrkdoYj7dMjPgBc4difZTbKg= MIME-Version: 1.0 Received: by 10.224.19.200 with SMTP id c8mr1213605qab.70.1285241306244; Thu, 23 Sep 2010 04:28:26 -0700 (PDT) Received: by 10.229.48.130 with HTTP; Thu, 23 Sep 2010 04:28:26 -0700 (PDT) In-Reply-To: References: Date: Thu, 23 Sep 2010 13:28:26 +0200 Message-ID: Subject: Re: "Internal error processing get" in get after insert ttl From: =?ISO-8859-1?Q?Michal_August=FDn?= To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=0015175cb2628266ed0490eb8f66 X-Virus-Checked: Checked by ClamAV on apache.org --0015175cb2628266ed0490eb8f66 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable 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:21= 8) at org.apache.cassandra.thrift.CassandraServer.readColumnFamily(CassandraServe= r.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(Custo= mTThreadPoolServer.java:167) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.j= ava: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(Names= QueryFilter.java:81) at org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilt= er.java:137) at org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilySt= ore.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(SliceByNamesReadComm= and.java:59) at org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(Storag= eProxy.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(Names= QueryFilter.java:81) at org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryFilt= er.java:137) at org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilySt= ore.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(SliceByNamesReadComm= and.java:59) at org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(Storag= eProxy.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.j= ava: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=FDn > wrote: > > Unfortunately, I'm running Cassandra on Windows platform and the loggin= g > > 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=FDn > >> wrote: > >> > Hello, > >> > I tried to use Column.Ttl property but I was not successful. My simp= le > >> > test: > >> > 1) insert column with ttl =3D 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 > --0015175cb2628266ed0490eb8f66 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable 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
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.service.StorageProxy.weakRea= d(StorageProxy.java:275)
=A0=A0 =A0 =A0 =A0at org.apache.cassandr= a.service.StorageProxy.readProtocol(StorageProxy.java:218)
=A0=A0= =A0 =A0 =A0at org.apache.cassandra.thrift.CassandraServer.readColumnFamily= (CassandraServer.java:115)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.thrift.CassandraServer.get(C= assandraServer.java:314)
=A0=A0 =A0 =A0 =A0at org.apache.cassandr= a.thrift.Cassandra$Processor$get.process(Cassandra.java:2747)
=A0= =A0 =A0 =A0 =A0at org.apache.cassandra.thrift.Cassandra$Processor.process(C= assandra.java:2647)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.thrift.CustomTThreadPoolServ= er$WorkerProcess.run(CustomTThreadPoolServer.java:167)
=A0=A0 =A0= =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoo= lExecutor.java:886)
=A0=A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.ru= n(ThreadPoolExecutor.java:908)
=A0=A0 =A0 =A0 =A0at java.lang.Thr= ead.run(Thread.java:619)
Caused by: java.util.concurrent.Executio= nException: java.lang.IllegalStateException: column is not marked for delet= e
=A0=A0 =A0 =A0 =A0at java.util.concurrent.FutureTask$Sync.innerGet(Fut= ureTask.java:222)
=A0=A0 =A0 =A0 =A0at java.util.concurrent.Futur= eTask.get(FutureTask.java:83)
=A0=A0 =A0 =A0 =A0at org.apache.cas= sandra.service.StorageProxy.weakRead(StorageProxy.java:271)
=A0=A0 =A0 =A0 =A0... 9 more
Caused by: java.lang.IllegalSta= teException: column is not marked for delete
=A0=A0 =A0 =A0 =A0at= org.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
=
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.filter.QueryFilter.isRele= vant(QueryFilter.java:151)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.filter.NamesQueryFilter.c= ollectReducedColumns(NamesQueryFilter.java:81)
=A0=A0 =A0 =A0 =A0= at org.apache.cassandra.db.filter.QueryFilter.collectCollatedColumns(QueryF= ilter.java:137)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.ColumnFamilyStore.getTopL= evelColumns(ColumnFamilyStore.java:1025)
=A0=A0 =A0 =A0 =A0at org= .apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.ja= va:910)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.ColumnFamilyStore.getColumnFam= ily(ColumnFamilyStore.java:880)
=A0=A0 =A0 =A0 =A0at org.apache.c= assandra.db.Table.getRow(Table.java:322)
=A0=A0 =A0 =A0 =A0at org= .apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand= .java:59)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.service.StorageProxy$weakRea= dLocalCallable.call(StorageProxy.java:734)
=A0=A0 =A0 =A0 =A0at j= ava.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
=A0=A0 =A0 =A0 =A0at java.util.concurrent.FutureTask.run(FutureTask.java:1= 38)
=A0=A0 =A0 =A0 =A0... 3 more
ERROR 13:25:59,418 Fatal except= ion in thread Thread[READ_STAGE:3,5,main]
java.lang.IllegalStateE= xception: column is not marked for delete
=A0=A0 =A0 =A0 =A0at or= g.apache.cassandra.db.Column.getMarkedForDeleteAt(Column.java:108)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.filter.QueryFilter.isRele= vant(QueryFilter.java:151)
=A0=A0 =A0 =A0 =A0at org.apache.cassan= dra.db.filter.NamesQueryFilter.collectReducedColumns(NamesQueryFilter.java:= 81)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.filter.QueryFilt= er.collectCollatedColumns(QueryFilter.java:137)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.ColumnFamilyStore.getTopL= evelColumns(ColumnFamilyStore.java:1025)
=A0=A0 =A0 =A0 =A0at org= .apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.ja= va:910)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.db.ColumnFamilyStore.getColumnFam= ily(ColumnFamilyStore.java:880)
=A0=A0 =A0 =A0 =A0at org.apache.c= assandra.db.Table.getRow(Table.java:322)
=A0=A0 =A0 =A0 =A0at org= .apache.cassandra.db.SliceByNamesReadCommand.getRow(SliceByNamesReadCommand= .java:59)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.service.StorageProxy$weakRea= dLocalCallable.call(StorageProxy.java:734)
=A0=A0 =A0 =A0 =A0at j= ava.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
=A0=A0 =A0 =A0 =A0at java.util.concurrent.FutureTask.run(FutureTask.java:1= 38)
=A0=A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.ru= nTask(ThreadPoolExecutor.java:886)
=A0=A0 =A0 =A0 =A0at java.util= .concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
=A0=A0 =A0 =A0 =A0at java.lang.Thread.run(Thread.java:619)

Augi

2010/9/23 Jona= than Ellis <jbell= is@gmail.com>
cassandra.bat is looking for a file named log4j.properties on the classpath= .

On Thu, Sep 23, 2010 at 5:52 AM, Michal August=FDn
<augustyn.michal@gmail.com> wrote:
> Unfortunately, I'm running Cassandra on Windows platform and the l= ogging
> doesn't work; I'm not able to configure them properly respecti= vely.
> 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 <sy= lvain@yakaz.com>
>>
>> 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=FDn
>> <augustyn.michal@g= mail.com> wrote:
>> > Hello,
>> > I tried to use Column.Ttl property but I was not=A0successful= . My simple
>> > test:
>> > 1) insert column with ttl =3D 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=A0disappear) >> > 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

--0015175cb2628266ed0490eb8f66--