[ https://issues.apache.org/jira/browse/CASSANDRA-5106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
janwar dinata reopened CASSANDRA-5106: -------------------------------------- Hi, Still having the same exception thrown even with PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner > Stock example for using pig throws InvalidRequestException(why:Start token > sorts after end token) > ------------------------------------------------------------------------------------------------- > > Key: CASSANDRA-5106 > URL: https://issues.apache.org/jira/browse/CASSANDRA-5106 > Project: Cassandra > Issue Type: Bug > Components: Hadoop > Affects Versions: 1.2.0 > Environment: 1 node cluster with default cassandra.yaml > Reporter: janwar dinata > Assignee: Brandon Williams > Priority: Minor > Fix For: 1.2.1 > > > The setup: > This is from printenv > HADOOP_HOME=/home/Downloads/hadoop-1.1.1 > PIG_HOME=/home/Downloads/pig-0.10.0 > PIG_INITIAL_ADDRESS=localhost > PIG_RPC_PORT=9160 > PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner > This is from cassandra-cli > [default@PigTest] describe cluster; > Cluster Information: > Snitch: org.apache.cassandra.locator.SimpleSnitch > Partitioner: org.apache.cassandra.dht.Murmur3Partitioner > Schema versions: > b5fc9a82-fbdd-3cf5-af16-9c498c9f9a5c: [127.0.0.1] > Running test_storage.pig as > bin/pig_cassandra -x local test/test_storage.pig > after populating the cf as > cassandra-cli --host localhost --port 9160 < populate-cli.txt > throws > 2013-01-03 02:20:47,626 [Thread-4] INFO > org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader > - Current spli > t being processed ColumnFamilySplit((-1, '-1728690256123413808] > @[localhost.localdomain]) > 2013-01-03 02:20:47,758 [Thread-4] WARN > org.apache.hadoop.mapred.FileOutputCommitter - Output path is null in cleanup > 2013-01-03 02:20:47,760 [Thread-4] WARN > org.apache.hadoop.mapred.LocalJobRunner - job_local_0001 > java.lang.RuntimeException: InvalidRequestException(why:Start token sorts > after end token) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.maybeInit(ColumnFamilyRecordReader.java:384) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.computeNext(ColumnFamilyRecordReader.java:390) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.computeNext(ColumnFamilyRecordReader.java:313) > at > com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) > at > com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFamilyRecordReader.java:184) > at > org.apache.cassandra.hadoop.pig.CassandraStorage.getNext(CassandraStorage.java:226) > at > org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader.nextKeyValue(PigRecordReader.java:194) > at > org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:532) > at > org.apache.hadoop.mapreduce.MapContext.nextKeyValue(MapContext.java:67) > at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:143) > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764) > at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370) > at > org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) > Caused by: InvalidRequestException(why:Start token sorts after end token) > at > org.apache.cassandra.thrift.Cassandra$get_range_slices_result.read(Cassandra.java:12916) > at > org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) > at > org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:734) > at > org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java:718) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.maybeInit(ColumnFamilyRecordReader.java:346) > ... 13 more -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira