[
https://issues.apache.org/jira/browse/CASSANDRA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
B. Todd Burruss updated CASSANDRA-1477:
---------------------------------------
Attachment: RaceConditionTest.java
using latest trunk code as of now
The attached JUnit (method testRaceTooFast) illustrates the problem of data
still existing even though the column family has been dropped and recreated,
but no data inserted.
However, I cannot make the test fail by throwing
"org.apache.thrift.TApplicationException: Internal error processing get_slice"
as i indicate before because the first problem above never corrects itself.
The data file never goes away no matter how long i wait. not sure what i was
doing different in my app, or possibly code changed. i no longer do it this
way in my app so not sure.
in addition, i tried to drop the keyspace between tests to make sure the
keyspace was "clear" and this returns
"InvalidRequestException(why:java.io.IOException: Unable to create compaction
marker)" when the keyspace does exist, but i guess i dropped the column family
during the previous test and caused it grief. not sure.
good luck!
> drop/recreate column family race condition
> ------------------------------------------
>
> Key: CASSANDRA-1477
> URL: https://issues.apache.org/jira/browse/CASSANDRA-1477
> Project: Cassandra
> Issue Type: Bug
> Components: Core
> Affects Versions: 0.7 beta 2
> Environment: 1 Node cluster, latest code from 0.7 trunk
> Reporter: B. Todd Burruss
> Assignee: Gary Dusbabek
> Fix For: 0.7 beta 2
>
> Attachments: RaceConditionTest.java
>
>
> using 0.7 latest from trunk as of few minutes ago. 1 client, 1 node
> i have the scenario where i want to drop a column family and recreate it
> - unit testing for instance, is a good reason you may want to do this
> (always start fresh).
> the problem i observe is that if i do the following:
> 1 - drop the column family
> 2 - recreate it
> 3 - read data from a key that existed before dropping, but doesn't exist now
> if those steps happen fast enough, i will get the old row - definitely
> no good.
> if they happen slow enough, get_slice throws:
> "org.apache.thrift.TApplicationException: Internal error processing
> get_slice"
> .. and on the server i see:
> 2010-09-07 13:53:48,086 ERROR
> [org.apache.cassandra.thrift.Cassandra$Processor] (pool-1-thread-4:) -
> Internal error processing get_slice
> java.lang.RuntimeException: java.util.concurrent.ExecutionException:
> java.io.IOError: java.io.FileNotFoundException:
> cassandra-data/data/Queues/test_1283892789285_Waiting-e-1-Data.db (No
> such file or directory)
> 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:114)
> at
> org.apache.cassandra.thrift.CassandraServer.getSlice(CassandraServer.java:220)
> at
> org.apache.cassandra.thrift.CassandraServer.multigetSliceInternal(CassandraServer.java:299)
> at
> org.apache.cassandra.thrift.CassandraServer.get_slice(CassandraServer.java:260)
> at
> org.apache.cassandra.thrift.Cassandra$Processor$get_slice.process(Cassandra.java:2795)
> at
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2651)
> 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.io.IOError:
> java.io.FileNotFoundException:
> cassandra-data/data/Queues/test_1283892789285_Waiting-e-1-Data.db (No
> such file or directory)
> 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)
> ... 11 more
> Caused by: java.io.IOError: java.io.FileNotFoundException:
> cassandra-data/data/Queues/test_1283892789285_Waiting-e-1-Data.db (No
> such file or directory)
> at
> org.apache.cassandra.io.util.BufferedSegmentedFile.getSegment(BufferedSegmentedFile.java:68)
> at
> org.apache.cassandra.io.sstable.SSTableReader.getFileDataInput(SSTableReader.java:509)
> at
> org.apache.cassandra.db.columniterator.SSTableSliceIterator.<init>(SSTableSliceIterator.java:49)
> at
> org.apache.cassandra.db.filter.SliceQueryFilter.getSSTableColumnIterator(SliceQueryFilter.java:65)
> at
> org.apache.cassandra.db.filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:76)
> at
> org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:961)
> at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:856)
> at
> org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:826)
> at org.apache.cassandra.db.Table.getRow(Table.java:321)
> at
> org.apache.cassandra.db.SliceFromReadCommand.getRow(SliceFromReadCommand.java:63)
> at
> org.apache.cassandra.service.StorageProxy$weakReadLocalCallable.call(StorageProxy.java:737)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> ... 3 more
> Caused by: java.io.FileNotFoundException:
> cassandra-data/data/Queues/test_1283892789285_Waiting-e-1-Data.db (No
> such file or directory)
> at java.io.RandomAccessFile.open(Native Method)
> at java.io.RandomAccessFile.<init>(RandomAccessFile.java:212)
> at java.io.RandomAccessFile.<init>(RandomAccessFile.java:98)
> at
> org.apache.cassandra.io.util.BufferedRandomAccessFile.<init>(BufferedRandomAccessFile.java:142)
> at
> org.apache.cassandra.io.util.BufferedSegmentedFile.getSegment(BufferedSegmentedFile.java:62)
> ... 15 more
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
