java - IOException:无法初始化群集Hadoop 2.4.0

标签 java hadoop jar hadoop2

我正在尝试使用hadoop 2.4.0运行Map-reduce
我的代码依赖于第三方jar,因此我使用eclipse export-> runnable Jar选项创建了FAT jar。

现在当我使用以下命令运行FAT jar时

       hadoop jar ~/Documents/job.jar

我异常(exception)
      java.lang.reflect.InvocationTargetException

上面的异常是由以下原因引起的:
Caused by: java.io.IOException: Cannot initialize Cluster. Please check your configuration for mapreduce.framework.name and the correspond server addresses.
at org.apache.hadoop.mapreduce.Cluster.initialize(Cluster.java:120)
at org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:82)
at org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:75)
at org.apache.hadoop.mapreduce.Job$9.run(Job.java:1255)
at org.apache.hadoop.mapreduce.Job$9.run(Job.java:1251)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
at org.apache.hadoop.mapreduce.Job.connect(Job.java:1250)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:1279)
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:1303)
at imgProc.MasterClass.main(MasterClass.java:84)
... 10 more

hadoop的类路径
hduser@livingstream:/usr/local/hadoop$ hadoop classpath
/usr/local/hadoop-2.4.0/etc/hadoop:/usr/local/hadoop-`2.4.0/share/hadoop/common/lib/*:/usr/local/hadoop-2.4.0/share/hadoop/common/*:/usr/local/hadoop-2.4.0/share/hadoop/hdfs:/usr/local/hadoop-2.4.0/share/hadoop/hdfs/lib/*:/usr/local/hadoop-2.4.0/share/hadoop/hdfs/*:/usr/local/hadoop-2.4.0/share/hadoop/yarn/lib/*:/usr/local/hadoop-2.4.0/share/hadoop/yarn/*:/usr/local/hadoop-2.4.0/share/hadoop/mapreduce/lib/*:/usr/local/hadoop-2.4.0/share/hadoop/mapreduce/*:/usr/local/hadoop/contrib/capacity-scheduler/*.jar`

我的配置文件

mapred-site.xml
<configuration>

    <property>
        <name>mapreduce.framework.name</name>
        <value>yarn</value>
    </property>


</configuration>

core-site.xml
<configuration>

<property>
  <name>fs.default.name</name>
  <value>hdfs://localhost:54310</value>
</property>
<property>
  <name>hadoop.tmp.dir</name>
  <value>/usr/local/hadoop/data</value>
</property>



</configuration>

yarn-site.xml
<configuration>

<!-- Site specific YARN configuration properties -->
  <property>
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>
    <property>
        <name>yarn.nodemanager.aux-services.mapreduce_shuffle.class</name>
        <value>org.apache.hadoop.mapred.ShuffleHandler</value>
    </property>
    <property>
        <name>yarn.resourcemanager.resource-tracker.address</name>
        <value>localhost:8025</value>
    </property>
    <property>
        <name>yarn.resourcemanager.scheduler.address</name>
        <value>localhost:8030</value>
    </property>
    <property>
        <name>yarn.resourcemanager.address</name>
        <value>localhost:8050</value>
    </property>
</configuration>

我不确定现在发生了什么,是因为JAR还是我的配置文件。
任何人都有任何想法,任何事情都值得赞赏! :)

最佳答案

错误消息明确指出,

Caused by: java.io.IOException: Cannot initialize Cluster. Please check your configuration for mapreduce.framework.name and the correspond server addresses.  

您必须配置mapred-site.xml and core-site.xml和许多其他配置。
要逐步了解,请引用此链接Hadoop V2 setup

希望这对您有所帮助。

关于java - IOException:无法初始化群集Hadoop 2.4.0,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27007018/

相关文章:

Java 数组列表获取

java - 使用 FileUtils.listFiles 递归查找目录

hadoop - 在hadoop中合并小文件

java - 如何检查一个 jar 是否是多版本的

java - map 无法放大

Java:如何在位置更改时显示/隐藏网络应用程序中的工作指示器?

java - Hadoop MapReduce作业可实现最高频率

hadoop - 使用 mapr-setup 脚本安装 mapr

java - Jar 有所不同,但它们不应该

java - 为 Maven 存储库创建 jar,如何?