首页 > 编程语言 >跨集群distcp数据的时候报错异常java.nio.channels.UnresolvedAddressException

跨集群distcp数据的时候报错异常java.nio.channels.UnresolvedAddressException

时间:2022-10-11 13:34:25浏览次数:51  
标签:hdfs UnresolvedAddressException java hadoop 报错 apache org estimate

异常

2022-10-10 19:41:55,541 INFO [IPC Server handler 17 on 33142] org.apache.hadoop.mapred.TaskAttemptListenerImpl: Diagnostics report from attempt_1663912973547_0434_m_000000_0: Error: java.io.IOException: File copy failed: hdfs://10.255.128.198:8020/user/hive/warehouse/vaas_dws.db/dws_ac_estimate_soh_yuce_partion/model_estimate_date=2022-09-27/000000_0 --> hdfs://10.246.97.4:8020/user/hive/warehouse/vaas_dws.db/dws_ac_estimate_soh_yuce_partion/dws_ac_estimate_soh_yuce_partion/model_estimate_date=2022-09-27/000000_0
at org.apache.hadoop.tools.mapred.CopyMapper.copyFileWithRetry(CopyMapper.java:259)
at org.apache.hadoop.tools.mapred.CopyMapper.map(CopyMapper.java:217)
at org.apache.hadoop.tools.mapred.CopyMapper.map(CopyMapper.java:48)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:146)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:799)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:347)
at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:174)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875)
at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:168)
Caused by: java.io.IOException: Couldn't run retriable-command: Copying hdfs://10.255.128.198:8020/user/hive/warehouse/vaas_dws.db/dws_ac_estimate_soh_yuce_partion/model_estimate_date=2022-09-27/000000_0 to hdfs://10.246.97.4:8020/user/hive/warehouse/vaas_dws.db/dws_ac_estimate_soh_yuce_partion/dws_ac_estimate_soh_yuce_partion/model_estimate_date=2022-09-27/000000_0
at org.apache.hadoop.tools.util.RetriableCommand.execute(RetriableCommand.java:101)
at org.apache.hadoop.tools.mapred.CopyMapper.copyFileWithRetry(CopyMapper.java:256)
... 10 more
Caused by: java.io.IOException: java.nio.channels.UnresolvedAddressException
at org.apache.hadoop.hdfs.ExceptionLastSeen.set(ExceptionLastSeen.java:45)
at org.apache.hadoop.hdfs.DataStreamer.run(DataStreamer.java:829)
Caused by: java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:101)
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622)
at org.apache.hadoop.net.SocketIOWithTimeout.connect(SocketIOWithTimeout.java:192)
at org.apache.hadoop.net.NetUtils.connect(NetUtils.java:531)
at org.apache.hadoop.hdfs.DataStreamer.createSocketForPipeline(DataStreamer.java:253)
at org.apache.hadoop.hdfs.DataStreamer.createBlockOutputStream(DataStreamer.java:1725)
at org.apache.hadoop.hdfs.DataStreamer.nextBlockOutputStream(DataStreamer.java:1679)
at org.apache.hadoop.hdfs.DataStreamer.run(DataStreamer.java:716)

解决方案:(异常的原因是因为跨集群的时候无法解析跨集群的namenode的主机导致的)

需要把两个集群的hosts合并重新distcp后数据正常

标签:hdfs,UnresolvedAddressException,java,hadoop,报错,apache,org,estimate
From: https://blog.51cto.com/wang/5746186

相关文章

  • java.sql.SQLException: ORA-01000: maximum open cursors exceeded;问题的解决方法
    转:https://blog.csdn.net/ALEX_wxy/article/details/83901129ora-01000:maximumopencursorsexceeded:表示已经达到一个进程打开的最大游标数。1.主要原因:Java代码在执......
  • Java Web 005
    DQL:对数据进行查询基本查询:select列名1,列名2from表名;--查询指定列select*from表名;--查询所有列select列名1,列名2from表名;-- 查询单列......
  • 支持 Java 8/11/17/19 的框架,Solon v1.10.5 版本发布
    Java轻量级应用开发框架。可用来快速开发Java应用项目,主框架仅0.1MB。相对于SpringBoot和SpringCloud的项目:启动快5~10倍。(更快)qps高2~3倍。(更高)......
  • Java实现队列
    队列是典型的FIFO数据结构。入队(队尾添加),出队(队首删除)。定义队列接口publicinterfaceQueue<T>{booleanenQueue(Tt);TdeQueue();intsize();}......
  • ACWing Java基础语法记录-类与接口
    类可以将变量、函数完美地打包在一起。类与对象类定义一种全新的数据类型,包含一组变量和函数;对象是类这种类型对应的实例。解释:例如在一间教室中,可以将'Student'定义成......
  • JavaScript高级程序设计笔记06 集合引用类型
    集合引用类型1.Object(详见c08p205)适合存储,在应用程序间交换数据创建实例:a.显式构造函数b.字面量——>不会调用构造函数(代码更少、更有封装感)函数:大量参数的情况......
  • windows系统下安装gym运行atari游戏报错:ale_interface/ale_c.dll OSError
    安装gym的atari支持:pip install gym[atari]  为gym下的atari环境下载游戏镜像ROMs文件:​需要注意的是由于gym的版本更新现在的gym依赖的atari库已经不叫做atari-py了,......
  • 「Java 数据结构」:手撕单链表的增删改查及大厂面试题。
    目录​​一、单链表的增删改查​​​​1、创建结点     ​​​​2、单链表的添加操作​​​​3、单链表的删除操作​​​​4、单链表的有效结点的个数​​​​二、......
  • JAVA数据类型
    JAVA数据类型基本数据类型数值类型整数型byte:一个字节short:两个字节int:四个字节long:八个字节注意:二进制0b 十进制 八进制0 十六进制0xlong类型要在数......
  • Java拦截器
    (1)浏览器发送一个请求会先到Tomcat的web服务器(2)Tomcat服务器接收到请求以后,会去判断请求的是静态资源还是动态资源(3)如果是静态资源,会直接到Tomcat的项目部署目录下......