在集群中运行mapreduce程序:
hadoop jar wordcountcb.jar hdfs://ns1/data/word.txt hdfs://ns1/out97
报错: 16/06/2403:18:09 INFO mapreduce.Job: map 0%reduce 0% 16/06/2403:18:21 INFO mapreduce.Job: Task Id : attempt_1466708453550_0002_m_000000_0,Status : FAILED Error:java.lang.RuntimeException: java.lang.NoSuchMethodException:com.k3.mapreduce.WordCountCB$WordCBMapper.<init>()
map和reduce类都是内部类,将程序中的内部类改成static则不会报错,如: static class WordCBMapper extends Mapper<LongWritable, Text, Text, LongWritable> { 。。。。。。 } 谁知道具体原因。
|