java - 如何在Amazon EMR中运行WordCount？

Question

在Amazon EMR中指定输入和输出路径的正确方法是什么？

在集群中，我单击Add Step，然后选择“自定义Jar”，然后输入jar位置s3://wordcountbuckett/wc.jar。对于参数输入框，我已将s3://wordcountbuckett/file01指定为我的输入文件，并将s3://wordcountbuckett/output/指定为我的输出路径。

file01是txt文件，而/ output /是文件夹。

以下是我从日志中获得的错误

Exception in thread "main" java.lang.ClassNotFoundException: s3://wordcountbuckett/
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:278)
    at org.apache.hadoop.util.RunJar.run(RunJar.java:214)
    at org.apache.hadoop.util.RunJar.main(RunJar.java:136)

My Add Step details:
1. Step Type : Custom Jar
2. Name : WordCount2
3. JAR Location : s3://mywordcountbuckett/binary/wc.jar
4. Arguments: s3://mywordcountbuckett/input/
s3://mywordcountbuckett/output/
5. Action on Failure : Continue

Answer 1

您确定指定了正确的路径吗？因为在文本中您谈论的是s3://wordcountbuckett/wc.jar，但是在添加步骤配置中，您指定s3://mywordcountbuckett/..。我建议检查这是问题还是错字。