1

我正在尝试流式传输由 Mahout 示例之一生成的序列文件以查看其内容：

    hadoop jar hadoop-streaming-0.20.2-cdh3u0.jar \
    -input /tmp/mahout-work-me/20news-bydate/bayes-test-input-output/ \
    -output /tmp/me/mm \
    -mapper "cat" \
    -reducer "wc -l" \
    -inputformat SequenceFileAsTextInputFormat

作业成功启动并最终终止：

11/11/30 21:08:39 INFO streaming.StreamJob:  map 0%  reduce 0%
11/11/30 21:09:17 INFO streaming.StreamJob:  map 100%  reduce 100%
java.lang.RuntimeException: java.io.IOException: WritableName can't load class: org.apache.mahout.common.StringTuple

我想知道我的流式 jar 文件是否有问题，是否需要明确指向具有此类的 Mahout jar（尝试将 HADOOP_CLASSPATH 设置为 mahout-core-0.5-cdh3u2.jar 的位置但不起作用），或者也许甚至是别的东西？

任何帮助表示赞赏。谢谢。

4

1 回答 1

2

添加此选项：

-libjars mahout-core-0.5-cdh3u2.jar
于 2011-12-01T15:13:26.527 回答