cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chander S Pechetty (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CASSANDRA-6793) NPE in Hadoop Word count example
Date Sun, 02 Mar 2014 13:44:19 GMT

     [ https://issues.apache.org/jira/browse/CASSANDRA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Chander S Pechetty updated CASSANDRA-6793:
------------------------------------------

    Attachment: trunk-6793.txt

> NPE in Hadoop Word count example
> --------------------------------
>
>                 Key: CASSANDRA-6793
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-6793
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Examples
>            Reporter: Chander S Pechetty
>            Priority: Minor
>         Attachments: trunk-6793.txt
>
>
> The partition keys requested in WordCount.java do not match the primary key set up in
the table output_words. It looks this patch was not merged properly from [CASSANDRA-5622|https://issues.apache.org/jira/browse/CASSANDRA-5622].The
attached patch addresses the NPE and uses the correct keys defined in #5622.
> I am assuming there is no need to fix the actual NPE like throwing an InvalidRequestException
back to user to fix the partition keys, as it would be trivial to get the same from the TableMetadata
using the driver API.
> java.lang.NullPointerException
> 	at org.apache.cassandra.dht.Murmur3Partitioner.getToken(Murmur3Partitioner.java:92)
> 	at org.apache.cassandra.dht.Murmur3Partitioner.getToken(Murmur3Partitioner.java:40)
> 	at org.apache.cassandra.client.RingCache.getRange(RingCache.java:117)
> 	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.write(CqlRecordWriter.java:163)
> 	at org.apache.cassandra.hadoop.cql3.CqlRecordWriter.write(CqlRecordWriter.java:63)
> 	at org.apache.hadoop.mapred.ReduceTask$NewTrackingRecordWriter.write(ReduceTask.java:587)
> 	at org.apache.hadoop.mapreduce.TaskInputOutputContext.write(TaskInputOutputContext.java:80)
> 	at WordCount$ReducerToCassandra.reduce(Unknown Source)
> 	at WordCount$ReducerToCassandra.reduce(Unknown Source)
> 	at org.apache.hadoop.mapreduce.Reducer.run(Reducer.java:176)
> 	at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:649)
> 	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:417)
> 	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Mime
View raw message