EOFException with Cassandra.Client.get_range_slices() API
---------------------------------------------------------
Key: CASSANDRA-1073
URL: https://issues.apache.org/jira/browse/CASSANDRA-1073
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 0.7
Reporter: Frank Du
Below is the snippet I tried to run. The keyspace is named 'Keyspac1', with
only 1 column family named 'CF1'.
ColumnParent cp = new ColumnParent(columnPath);
SlicePredicate predicate = new SlicePredicate();
SliceRange sliceRange = new SliceRange();
sliceRange.setStart(new byte[0]);
sliceRange.setFinish(new byte[0]);
predicate.setSlice_range(sliceRange);
KeyRange range = new KeyRange(10);
range.setStart_key("".getBytes());
range.setEnd_key("".getBytes());
client.set_keyspace(keyspace);
List<KeySlice> slices = client.get_range_slices(cp, predicate,
range, ConsistencyLevel.ONE);
Then an EOFException was spit out. Below is the runtime log:
======================================================
10/05/10 13:46:44 INFO config.DatabaseDescriptor: Auto DiskAccessMode
determined to be mmap
10/05/10 13:46:44 INFO sstable.SSTableReader: Sampling index for
/Users/fdu/Documents/workspace/working/CassandraProject/var/data/system/Schema-c-1-<>
10/05/10 13:46:44 INFO sstable.SSTableReader: Sampling index for
/Users/fdu/Documents/workspace/working/CassandraProject/var/data/system/Migrations-c-1-<>
10/05/10 13:46:44 INFO sstable.SSTableReader: Sampling index for
/Users/fdu/Documents/workspace/working/CassandraProject/var/data/system/LocationInfo-c-9-<>
10/05/10 13:46:45 INFO config.DatabaseDescriptor: Loading schema version
5236f8e4-5b11-11df-b0b8-e700f669bcfc
10/05/10 13:46:45 INFO sstable.SSTableReader: Sampling index for
/Users/fdu/Documents/workspace/working/CassandraProject/var/data/Keyspace1/CF1-c-1-<>
10/05/10 13:46:45 INFO sstable.SSTableReader: Sampling index for
/Users/fdu/Documents/workspace/working/CassandraProject/var/data/Keyspace1/CF1-c-2-<>
10/05/10 13:46:45 WARN config.DatabaseDescriptor: Schema definitions were
defined both locally and in cassandra.yaml. Definitions in cassandra.yaml were
ignored.
10/05/10 13:46:45 INFO commitlog.CommitLog: Replaying
/Users/fdu/Documents/workspace/working/CassandraProject/var/commitlog/CommitLog-1273371489900.log,
/Users/fdu/Documents/workspace/working/CassandraProject/var/commitlog/CommitLog-1273371579896.log
10/05/10 13:46:45 INFO commitlog.CommitLog: Log replay complete
10/05/10 13:46:45 INFO db.SystemTable: Saved Token found:
127450579207552179228696892900403280695
10/05/10 13:46:45 INFO db.SystemTable: Saved ClusterName found: Test Cluster
10/05/10 13:46:45 INFO commitlog.CommitLogSegment: Creating new commitlog
segment
/Users/fdu/Documents/workspace/working/CassandraProject/var/commitlog/CommitLog-1273513605319.log
10/05/10 13:46:45 INFO service.StorageService: Starting up server gossip
10/05/10 13:46:45 INFO thrift.CassandraDaemon: Binding thrift service to
localhost/127.0.0.1:9160
10/05/10 13:46:45 INFO thrift.CassandraDaemon: Cassandra starting up...
10/05/10 13:46:45 INFO utils.Mx4jTool: Will not load MX4J, mx4j-tools.jar is
not in the classpath
10/05/10 13:47:43 ERROR concurrent.JMXEnabledThreadPoolExecutor: Error in
ThreadPoolExecutor
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
10/05/10 13:47:49 ERROR thrift.CassandraDaemon: Fatal exception in thread
Thread[ROW-READ-STAGE:3,5,main]
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
10/05/10 13:48:28 ERROR concurrent.JMXEnabledThreadPoolExecutor: Error in
ThreadPoolExecutor
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
10/05/10 13:48:32 ERROR thrift.CassandraDaemon: Fatal exception in thread
Thread[ROW-READ-STAGE:9,5,main]
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
10/05/10 13:54:25 ERROR thrift.Cassandra$Processor: Internal error processing
get_range_slices
java.lang.NumberFormatException: Zero length BigInteger
at java.math.BigInteger.<init>(BigInteger.java:276)
at java.math.BigInteger.<init>(BigInteger.java:451)
at
org.apache.cassandra.dht.RandomPartitioner$1.fromString(RandomPartitioner.java:121)
at
org.apache.cassandra.thrift.CassandraServer.get_range_slices(CassandraServer.java:504)
at
org.apache.cassandra.thrift.Cassandra$Processor$get_range_slices.process(Cassandra.java:1528)
at
org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:1215)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253)
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:637)
10/05/10 13:57:23 ERROR concurrent.JMXEnabledThreadPoolExecutor: Error in
ThreadPoolExecutor
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
10/05/10 13:57:41 ERROR thrift.CassandraDaemon: Fatal exception in thread
Thread[ROW-READ-STAGE:10,5,main]
java.lang.RuntimeException: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:54)
at
org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:41)
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:637)
Caused by: java.lang.RuntimeException: java.io.EOFException
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:200)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:133)
at
org.apache.cassandra.db.filter.SSTableSliceIterator.computeNext(SSTableSliceIterator.java:1)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at
org.apache.commons.collections.iterators.CollatingIterator.anyHasNext(CollatingIterator.java:364)
at
org.apache.commons.collections.iterators.CollatingIterator.hasNext(CollatingIterator.java:217)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:138)
at
org.apache.cassandra.db.RowIteratorFactory$3.getReduced(RowIteratorFactory.java:1)
at
org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:73)
at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:135)
at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:130)
at org.apache.cassandra.db.RowIterator.hasNext(RowIterator.java:49)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeRows(ColumnFamilyStore.java:877)
at
org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:925)
at
org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:42)
... 4 more
Caused by: java.io.EOFException
at java.io.RandomAccessFile.readByte(RandomAccessFile.java:591)
at
org.apache.cassandra.utils.FBUtilities.readShortByteArray(FBUtilities.java:346)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:59)
at
org.apache.cassandra.db.ColumnSerializer.deserialize(ColumnSerializer.java:1)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.getNextBlock(SSTableSliceIterator.java:235)
at
org.apache.cassandra.db.filter.SSTableSliceIterator$ColumnGroupReader.pollColumn(SSTableSliceIterator.java:195)
... 19 more
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
