Hadoop作業在FBUtilities.java中拋出NullPointerException

Question

嘗試啓動我的hadoop作業以訪問Cassandra時，出現NullPointerException。這裏談到的堆棧跟蹤：在線程

異常 「主」 顯示java.lang.NullPointerException 在org.apache.cassandra.utils.FBUtilities.newPartitioner（FBUtilities.java:415） 在org.apache.cassandra.hadoop .ConfigHelper.getOutputPartitioner（ConfigHelper.java:416） 在org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.checkOutputSpecs（ColumnFamilyOutputFormat.java:90） 在org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.checkOutputSpecs（ColumnFamilyOutputFormat.java:81 ） at org.apache.hadoop.mapred.JobClient $ 2.run（JobClient.java:887） at org.apache.hadoop.mapred.JobClient $ 2.run（JobClient.java:850） at java.security.AccessController .doPrivileged（NATIV e方法） at javax.security.auth.Subject.doAs（Subject.java:416） at org.apache.hadoop.security.UserGroupInformation.doAs（UserGroupInformation.java:1121） at org.apache.hadoop.mapred .JobClient.submitJobInternal（JobClient.java:850） 在org.apache.hadoop.mapreduce.Job.submit（Job.java:500） 在org.apache.hadoop.mapreduce.Job.waitForCompletion（Job.java:530 ） 在RowKeyIndexer.run（RowKeyIndexer.java:393） 在Indexer.run（Indexer.java:56） 在org.apache.hadoop.util.ToolRunner.run（ToolRunner.java:65） 在Indexer.main （Indexer.java:30） at sun.reflect.NativeMethodAccessorImpl.invoke0（Native Method） at sun.reflect.NativeMethodAccessorImpl.invoke（Nativ eMethodAccessorImpl.java:57） at sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43） at java.lang.reflect.Method.invoke（Method.java:616） at org.apache.hadoop.util。 RunJar.main（RunJar.java:156）

我運行的hadoop版本1.0.3和cassandra版本1.1.2。

任何幫助是高度讚賞，因爲我不知道從哪裏開始。

非常感謝！

Answer 1

它看起來像你沒有設置你的輸出parititioner，像這樣：

ConfigHelper.setOutputPartitioner(conf, "org.apache.cassandra.dht.RandomPartitioner");