You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Brandon Williams (JIRA)" <ji...@apache.org> on 2013/01/08 16:24:14 UTC
[jira] [Commented] (CASSANDRA-5106) Stock example for using pig
throws InvalidRequestException(why:Start token sorts after end token)
[ https://issues.apache.org/jira/browse/CASSANDRA-5106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13546941#comment-13546941 ]
Brandon Williams commented on CASSANDRA-5106:
---------------------------------------------
Regression from CASSANDRA-5076
> 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