hadoop - mapreduce作业失去连接,然后在hadoop示例 “calculating pi 3 3”中重新连接

标签 hadoop mapreduce

有人知道为什么吗?作业总是卡在进度中(不是0%),有时可能会断开然后重新连接,基本上,该作业无法完成!!!

分配给mapreduce的内存是否太少?期待帮助!

[debura@master mapreduce]hadoop jar hadoop-mapreduce-examples-2.7.3.jar pi 3 3
Number of Maps = 3 Samples per Map = 3
Wrote input for Map #0
Wrote input for Map #1
Wrote input for Map #2
Starting Job
19/12/05 21:04:20 INFO client.RMProxy: Connecting to ResourceManager at master/192.168.56.110:8032
19/12/05 21:04:21 INFO input.FileInputFormat: Total input paths to process : 3
19/12/05 21:04:22 INFO mapreduce.JobSubmitter: number of splits:3
19/12/05 21:04:22 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1575550949758_0001
19/12/05 21:04:23 INFO impl.YarnClientImpl: Submitted application application_1575550949758_0001
19/12/05 21:04:23 INFO mapreduce.Job: The url to track the job: http://master:8088/proxy/application_1575550949758_0001/
19/12/05 21:04:23 INFO mapreduce.Job: Running job: job_1575550949758_0001 19/12/05 21:04:30 INFO mapreduce.Job: Job job_1575550949758_0001 running in uber mode : false
19/12/05 21:04:30 INFO mapreduce.Job: map 0% reduce 0%
19/12/05 21:04:34 INFO mapreduce.Job: map 33% reduce 0%
19/12/05 21:04:45 INFO mapreduce.Job: map 33% reduce 11%
19/12/05 21:07:31 INFO mapreduce.Job: Task Id : attempt_1575550949758_0001_m_000001_0, Status : FAILED
Container launch failed for container_1575550949758_0001_01_000004 : java.net.ConnectException: Call From slave2/192.168.56.112 to localhost:42149 failed on connection exception: java.net.ConnectException: Connection refused; For more details see: http://wiki.apache.org/hadoop/ConnectionRefused
at sun.reflect.GeneratedConstructorAccessor47.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
...



然后重新连接

19/12/05 21:07:36 INFO mapreduce.Job: map 67% reduce 11%
19/12/05 21:07:37 INFO mapreduce.Job: map 67% reduce 22% 19/12/05 21:10:33 INFO mapreduce.Job: Task Id : attempt_1575550949758_0001_m_000000_1, Status : FAILED
Container launch failed for container_1575550949758_0001_01_000007 : java.net.ConnectException: Call From slave2/192.168.56.112 to localhost:42149 failed on connection exception: java.net.ConnectException: Connection refused; For more details see: http://wiki.apache.org/hadoop/ConnectionRefused
...

最佳答案

似乎datanode不在slave2上运行,或者hdfs-site.xml配置错误,客户端应从此处读取

From slave2/192.168.56.112 to localhost:42149 failed

关于hadoop - mapreduce作业失去连接,然后在hadoop示例 “calculating pi 3 3”中重新连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59205744/

相关文章:

hadoop - HBase 无法在 Mac OSX 上以单节点集群模式启动

java - Hadoop名称节点格式化窗口-java.lang.UnsupportedOperationException

hadoop - hbase 错误 : "10/12/26 06:48:07 INFO ipc.HbaseRPC: Server at/127.0.0.1:58920 could not be reached after 1 tries, giving up."

hadoop - Oozie Pig Action 更改作业 jar 的 Guava 依赖性

java - HBase:使用MapReduce更新行?

java - Hadoop:计算频率,然后在第二个map/reduce中设置变量

javascript - Map/Reduce 示例...这是正确的吗?

hadoop - 如何制作 Hadoop MapReduce 的 UML 组件图

csv - Hive 外部表未从 CSV 源读取整个字符串

hadoop - 卡在 Reduce Join 代码中