cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maxim Potekhin <potek...@bnl.gov>
Subject Re: delay in data deleting in cassadra
Date Sat, 21 Jan 2012 03:31:42 GMT
Did you run repairs withing GC_GRACE all the time?



On 1/20/2012 3:42 AM, Shammi Jayasinghe wrote:
> Hi,
>   I am experiencing a delay in delete operations in cassandra. Its as 
> follows. I am running a thread which contains following three steps.
>
> Step 01: Read data from column family "foo"    [1]
> Step 02: Process received data eg: bar1,bar2,bar3,bar4,bar5
> Step 03: Remove those processed data from "foo".[2]
>
>  The problem occurs when this thread is invoked for the second time.
> In that step , it returns some of data that i already deleted in the 
> third step of the previous cycle.
>
> Eg: it returns bar2,bar3,bar4,bar5
>
> It seems though i called the remove operation as follows [2], it takes 
> time to replicate it to
> the file system. If i make a thread sleep of 5 secs between the thread 
> cycles, it does not
> give me any data that i deleted in the third step.
>
>  [1] . SliceQuery<String, String, byte[]> sliceQuery =
>                     HFactory.createSliceQuery(keyspace, 
> stringSerializer, stringSerializer, bs);
>             sliceQuery.setKey(queueName);
>             sliceQuery.setRange("", "", false, messageCount);
>             sliceQuery.setColumnFamily(USER_QUEUES_COLUMN_FAMILY);
>
>  [2].  Mutator<String> mutator = HFactory.createMutator(keyspace, 
> stringSerializer);
>         mutator.addDeletion(queueName, USER_QUEUES_COLUMN_FAMILY, 
> messageId, stringSerializer);
>         mutator.execute();
>
>
> Is there a solution for this.
>
> Cassadra version : 0.8.0
> Libthrift version : 0.6.1
>
>
> Thanks
> Shammi
> -- 
> Best Regards,*
>
> Shammi Jayasinghe*
> Senior Software Engineer; WSO2, Inc.; http://wso2.com <http://wso2.com/>,
> mobile: +94 71 4493085
>
>


Mime
View raw message