cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shammi Jayasinghe <sha...@wso2.com>
Subject delay in data deleting in cassadra
Date Fri, 20 Jan 2012 11:42:38 GMT
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,
mobile: +94 71 4493085

Mime
View raw message