From cassandra-user-return-2408-apmail-incubator-cassandra-user-archive=incubator.apache.org@incubator.apache.org Tue Feb 02 16:02:38 2010 Return-Path: Delivered-To: apmail-incubator-cassandra-user-archive@minotaur.apache.org Received: (qmail 4740 invoked from network); 2 Feb 2010 16:02:38 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 2 Feb 2010 16:02:38 -0000 Received: (qmail 63439 invoked by uid 500); 2 Feb 2010 16:02:37 -0000 Delivered-To: apmail-incubator-cassandra-user-archive@incubator.apache.org Received: (qmail 63416 invoked by uid 500); 2 Feb 2010 16:02:37 -0000 Mailing-List: contact cassandra-user-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: cassandra-user@incubator.apache.org Delivered-To: mailing list cassandra-user@incubator.apache.org Received: (qmail 63407 invoked by uid 99); 2 Feb 2010 16:02:37 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Feb 2010 16:02:37 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [216.252.121.69] (HELO web43139.mail.sp1.yahoo.com) (216.252.121.69) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 02 Feb 2010 16:02:29 +0000 Received: (qmail 42717 invoked by uid 60001); 2 Feb 2010 16:02:08 -0000 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yahoo.com; s=s1024; t=1265126528; bh=KzRYeNDm7nSrYb3f7Mu0ObazbEfRyQqDjleVd1SeWgE=; h=Message-ID:X-YMail-OSG:Received:X-Mailer:References:Date:From:Subject:To:In-Reply-To:MIME-Version:Content-Type; b=6HLLUxFIIxZEN9vmShh31wRzfBxZ1keC1jKkHl2jimelomLMAb2iQZqu3Zi/Y9+zsriSxxcNTBcrk8xIsRzBPOlKKZSjohsNDC3/rc5FehyuL79pQcTISompk2GbcLoloJVEon0XfZo1MkkYdhhGr02t2emFW/GBXHKcOkbUhLM= DomainKey-Signature:a=rsa-sha1; q=dns; c=nofws; s=s1024; d=yahoo.com; h=Message-ID:X-YMail-OSG:Received:X-Mailer:References:Date:From:Subject:To:In-Reply-To:MIME-Version:Content-Type; b=HuMqB8M++Vp6sOeNkAqZgsKYEoyL56k1zJvLTCuaZBXc2Zbuh3IHHhzXDaTX+xwJ6v9LQpfRILOaw+iME/fbZERunFsG9CdQLnekYMFzmFqza76Uv9QsumviL3swAUHRGA3/9FSKEE9DJBHwcVltCjZQMWj8VuV4S2Qg5MG/8Es=; Message-ID: <314650.42503.qm@web43139.mail.sp1.yahoo.com> X-YMail-OSG: Ju9YiKgVM1n5mf9IH.N_udSr4xjgFd6XVFsOdO_DdL.Wk1HaoI9362120Jd_M2iLhOdRldqisXzdCCpiV60U6uxgh.N.AlSumoWznJ0iz81feuAP87aqjuzoSaMtkSkDtM23yoc2CElmN5QMub__D7W0BTne8H40hHzh_EuXSsfzIfHBq7FKIIB0FOy8i2o.PwF59ok9FidrR4KWORBSQ4F9ElmKZ0GB7.c4htgLMOxutgm7ERJVu_rYAGi2zMilVVzZ4XR4UBHA81Qvmg0xURfCr3qYLbFruD_vAMYKgzcCkq_ijCTkzYCbpikSnaQrqm.0nnEDhjOXnee3RHkLqrZ.oMIjQDghEGQeYPh9dRV_wWjaFADqpw-- Received: from [12.91.112.126] by web43139.mail.sp1.yahoo.com via HTTP; Tue, 02 Feb 2010 08:02:07 PST X-Mailer: YahooMailRC/272.7 YahooMailWebService/0.8.100.260964 References: <584478.42769.qm@web43142.mail.sp1.yahoo.com> <852449.65039.qm@web43139.mail.sp1.yahoo.com> Date: Tue, 2 Feb 2010 08:02:07 -0800 (PST) From: Omer van der Horst Jansen Subject: Re: Did CASSANDRA-647 get fixed in 0.5? To: cassandra-user@incubator.apache.org In-Reply-To: MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="0-1282277662-1265126527=:42503" --0-1282277662-1265126527=:42503 Content-Type: text/plain; charset=us-ascii Here it is: https://issues.apache.org/jira/browse/CASSANDRA-752 ________________________________ From: Jonathan Ellis To: cassandra-user@incubator.apache.org Sent: Mon, February 1, 2010 5:22:13 PM Subject: Re: Did CASSANDRA-647 get fixed in 0.5? Can you create a ticket for this? Thanks! On Mon, Feb 1, 2010 at 4:11 PM, Omer van der Horst Jansen wrote: > I checked out the 0.5 branch and ran ant release (on my linux box). > Installed the new tar.gz and ran the test on my Windows laptop as before but > got the same result -- the key isn't deleted from the perspective of > get_range_slice. > > Omer > > ________________________________ > From: Jonathan Ellis > To: cassandra-user@incubator.apache.org > Sent: Mon, February 1, 2010 4:52:17 PM > Subject: Re: Did CASSANDRA-647 get fixed in 0.5? > > 647 was committed for 0.5, yes, but CASSANDRA-703 was not. Can you > try the 0.5 branch and see if it is fixed there? > > On Mon, Feb 1, 2010 at 3:26 PM, Omer van der Horst Jansen > wrote: >> I'm running >> into an issue with Cassandra 0.5 (the current release version) that >> sounds exactly like the description of issue CASSANDRA-647. >> >> I'm >> using the Thrift Java API to store a couple of columns in a single row. A >> few seconds after that my application deletes the entire row. A plain >> Cassandra.Client.get() will then throw a NotFoundException for that >> particular key, as expected. However, the key will still show up when >> executing a >> Cassandra.Client.get_range_slice query. >> >> Here is some quick and >> dirty Java code that demonstrates the problem: >> >> import >> java.util.List; >> >> import org.apache.cassandra.service.*; >> import >> org.apache.thrift.protocol.*; >> import org.apache.thrift.transport.*; >> >> public class Cassandra647TestApp >> { >> /** >> * Demonstrates >> CASSANDRA-647 presence in Cassandra 0.5 release. >> * Requires an >> unmodified Cassandra configuration except that an >> * >> OrderPreservingPartitioner should be used. >> */ >> public >> static void main(String[] args) throws Exception >> { >> >> String keyspace = "Keyspace1"; >> String cf = "Standard1"; >> String key = "testrow1"; >> byte[] columnName = >> "colname".getBytes(); >> byte[] data = "testdata".getBytes(); >> >> TTransport transport = new TSocket("localhost", 9160); >> TProtocol protocol = new TBinaryProtocol(transport); >> >> Cassandra.Client client = new Cassandra.Client(protocol); >> >> transport.open(); >> ColumnPath path = new ColumnPath(cf, null, >> columnName); >> >> client.insert(keyspace, key, path, data, >> System.currentTimeMillis(), >> ConsistencyLevel.ONE); >> >> Thread.sleep(1000); >> >> ColumnPath rowpath = new >> ColumnPath(cf, null, null); >> >> client.remove(keyspace, key, >> rowpath, System.currentTimeMillis(), >> >> ConsistencyLevel.ONE); >> Thread.sleep(1000); >> >> try >> { >> ColumnOrSuperColumn cosc = client.get(keyspace, >> key, path, >> ConsistencyLevel.ONE); >> >> System.out.println("Whoops! NotFoundException not thrown!"); >> } >> catch (NotFoundException e) >> { >> >> System.out.println("OK, we got a NotFoundException"); >> } >> >> ColumnParent parent = new ColumnParent(cf, null); >> >> SlicePredicate predicate = new SlicePredicate(); >> SliceRange >> range = new SliceRange(); >> range.start = new byte[0]; >> range.finish = new byte[0]; >> predicate.slice_range = range; >> >> List sliceList = client.get_range_slice(keyspace, parent, >> predicate, "", "", 1000, >> ConsistencyLevel.ONE); >> >> for (KeySlice k : sliceList) >> { >> System.out.println("Found key " + k.key); >> if (key.equals(k.key)) >> { >> >> System.out.println("but key " + k.key >> + " >> should have been removed"); >> } >> } >> } >> } >> >> Am I using the API correctly in the code above? >> >> -Omer van der Horst Jansen >> >> >> >> >> > > --0-1282277662-1265126527=:42503 Content-Type: text/html; charset=us-ascii
Here it is: https://issues.apache.org/jira/browse/CASSANDRA-752


From: Jonathan Ellis <jbellis@gmail.com>
To: cassandra-user@incubator.apache.org
Sent: Mon, February 1, 2010 5:22:13 PM
Subject: Re: Did CASSANDRA-647 get fixed in 0.5?

Can you create a ticket for this?

Thanks!

On Mon, Feb 1, 2010 at 4:11 PM, Omer van der Horst Jansen
<omerhj@yahoo.com> wrote:
> I checked out the 0.5 branch and ran ant release (on my linux box).
> Installed the new tar.gz and ran the test on my Windows laptop as before but
> got the same result -- the key isn't deleted from the perspective of
> get_range_slice.
>
> Omer
>
> ________________________________
> From: Jonathan Ellis <jbellis@gmail.com>
> To: cassandra-user@incubator.apache.org
> Sent: Mon, February 1, 2010 4:52:17 PM
> Subject: Re: Did CASSANDRA-647 get fixed in 0.5?
>
> 647 was committed for 0.5, yes, but CASSANDRA-703 was not.  Can you
> try the 0.5 branch and see if it is fixed there?
>
> On Mon, Feb 1, 2010 at 3:26 PM, Omer van der Horst Jansen
> <omerhj@yahoo.com> wrote:
>> I'm running
>> into an issue with Cassandra 0.5 (the current release version) that
>> sounds exactly like the description of issue CASSANDRA-647.
>>
>> I'm
>> using the Thrift Java API to store a couple of columns in a single row. A
>> few seconds after that my application deletes the entire row. A plain
>> Cassandra.Client.get() will then throw a NotFoundException for that
>> particular key, as expected. However, the key will still show up when
>> executing a
>> Cassandra.Client.get_range_slice query.
>>
>> Here is some quick and
>> dirty Java code that demonstrates the problem:
>>
>> import
>> java.util.List;
>>
>> import org.apache.cassandra.service.*;
>> import
>> org.apache.thrift.protocol.*;
>> import org.apache.thrift.transport.*;
>>
>> public class Cassandra647TestApp
>> {
>>    /**
>>     * Demonstrates
>> CASSANDRA-647 presence in Cassandra 0.5 release.
>>     * Requires an
>> unmodified Cassandra configuration except that an
>>     *
>> OrderPreservingPartitioner should be used.
>>     */
>>    public
>> static void main(String[] args) throws Exception
>>    {
>>
>> String keyspace = "Keyspace1";
>>        String cf = "Standard1";
>>        String key = "testrow1";
>>        byte[] columnName =
>> "colname".getBytes();
>>        byte[] data = "testdata".getBytes();
>>
>>        TTransport transport = new TSocket("localhost", 9160);
>>        TProtocol protocol = new TBinaryProtocol(transport);
>>
>> Cassandra.Client client = new Cassandra.Client(protocol);
>>
>> transport.open();
>>        ColumnPath path = new ColumnPath(cf, null,
>> columnName);
>>
>>        client.insert(keyspace, key, path, data,
>> System.currentTimeMillis(),
>>                ConsistencyLevel.ONE);
>>
>>        Thread.sleep(1000);
>>
>>        ColumnPath rowpath = new
>> ColumnPath(cf, null, null);
>>
>>        client.remove(keyspace, key,
>> rowpath, System.currentTimeMillis(),
>>
>> ConsistencyLevel.ONE);
>>        Thread.sleep(1000);
>>
>>        try
>>        {
>>            ColumnOrSuperColumn cosc = client.get(keyspace,
>> key, path,
>>                    ConsistencyLevel.ONE);
>>
>> System.out.println("Whoops! NotFoundException not thrown!");
>>        }
>>        catch (NotFoundException e)
>>        {
>>
>> System.out.println("OK, we got a NotFoundException");
>>        }
>>
>>        ColumnParent parent = new ColumnParent(cf, null);
>>
>> SlicePredicate predicate = new SlicePredicate();
>>        SliceRange
>> range = new SliceRange();
>>        range.start = new byte[0];
>>        range.finish = new byte[0];
>>        predicate.slice_range = range;
>>
>>        List<KeySlice> sliceList = client.get_range_slice(keyspace, parent,
>>                predicate, "", "", 1000,
>> ConsistencyLevel.ONE);
>>
>>        for (KeySlice k : sliceList)
>>        {
>>            System.out.println("Found key " + k.key);
>>            if (key.equals(k.key))
>>            {
>>
>> System.out.println("but key " + k.key
>>                        + "
>> should have been removed");
>>            }
>>        }
>>    }
>> }
>>
>> Am I using the API correctly in the code above?
>>
>> -Omer van der Horst Jansen
>>
>>
>>
>>
>>
>
>

--0-1282277662-1265126527=:42503--