cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jonathan Ellis (JIRA)" <j...@apache.org>
Subject [jira] Commented: (CASSANDRA-153) get_key_range timeout and exception
Date Mon, 11 May 2009 14:31:46 GMT

    [ https://issues.apache.org/jira/browse/CASSANDRA-153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12708052#action_12708052
] 

Jonathan Ellis commented on CASSANDRA-153:
------------------------------------------

fixed two more bugs.  the first is what you were running into; SequenceFile and FileStruct
both assume when seeking that the block index exists at the end of the Coordinate computed
by SSTable.  But we weren't always consistent in specifying the index filename and instead
of raising an error Coordinate would just return something bogus.  these are both fixed in
02.

03 fixes a bug in FS iteration when no keys in the range specified exist in a given SSTable.

> get_key_range timeout and exception
> -----------------------------------
>
>                 Key: CASSANDRA-153
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-153
>             Project: Cassandra
>          Issue Type: Bug
>            Reporter: nk11
>         Attachments: 0001-CASSANDRA-153-unit-test-to-expose-bug-system-test-is-r.txt,
0002-cannonicalize-all-accesses-to-indexMeatdataMap.txt, 0003-check-for-at-end-of-data-in-iterator-init.txt,
153-02.patch, 153.patch
>
>
> My test code:
> 		int max = 5000;		
> 		for (int a = 0; a < max; a++) {
> 			System.out.println(a);
> 			client.insert("Table1", "k1:" + a, "Super1:x:x", new byte[] { (byte) 1 }, 0, false);
> 		}		
> 		client.get_key_range("Table1", "k1:0", "k1:1000", 1000);
> Produces in the logs:
> ERROR [ROW-READ-STAGE:9] 2009-05-07 23:04:56,609 CassandraDaemon.java (line 61) Fatal
exception in thread Thread[ROW-READ-STAGE:9,5,main]
> java.lang.RuntimeException: corrupt sstable
> 	at org.apache.cassandra.db.FileStruct.seekTo(FileStruct.java:107)
> 	at org.apache.cassandra.db.Table.getKeyRange(Table.java:905)
> 	at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:23)
> 	at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> 	at java.lang.Thread.run(Unknown Source)
> Caused by: java.io.EOFException
> 	at java.io.RandomAccessFile.readUnsignedShort(Unknown Source)
> 	at java.io.DataInputStream.readUTF(Unknown Source)
> 	at java.io.RandomAccessFile.readUTF(Unknown Source)
> 	at org.apache.cassandra.io.SequenceFile$AbstractReader.getPositionFromBlockIndex(SequenceFile.java:562)
> 	at org.apache.cassandra.db.FileStruct.seekTo(FileStruct.java:86)
> 	... 6 more
> ERROR [pool-1-thread-2] 2009-05-07 23:05:01,593 Cassandra.java (line 1187) Internal error
processing get_key_range
> java.lang.RuntimeException: error reading keyrange RangeCommand(table='Table1', startWith='k1:0',
stopAt='k1:1000', maxResults=1000)
> 	at org.apache.cassandra.service.StorageProxy.getKeyRange(StorageProxy.java:682)
> 	at org.apache.cassandra.service.CassandraServer.get_key_range(CassandraServer.java:511)
> 	at org.apache.cassandra.service.Cassandra$Processor$get_key_range.process(Cassandra.java:1183)
> 	at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:805)
> 	at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:252)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> 	at java.lang.Thread.run(Unknown Source)
> Caused by: java.util.concurrent.TimeoutException: Operation timed out.
> 	at org.apache.cassandra.net.AsyncResult.get(AsyncResult.java:95)
> 	at org.apache.cassandra.service.StorageProxy.getKeyRange(StorageProxy.java:677)
> 	... 7 more

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message