小标
2018-12-19
来源 :
阅读 1372
评论 0
摘要:本文主要向大家介绍了Java语言连接hdfs文件的时候报错,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。
本文主要向大家介绍了Java语言连接hdfs文件的时候报错,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。
今天在Java访问hdfs上文件的时候,报错:
2018-05-03 22:40:53.343 INFO 10158 --- [eduler_Worker-4] org.apache.hadoop.ipc.Client : Retrying connect to server: master/172.16.80.70:8020. Already tried 37 time(s); maxRetries=45
2018-05-03 22:40:56.292 INFO 10158 --- [eduler_Worker-5] o.a.c.httpclient.HttpMethodDirector : I/O exception (java.net.ConnectException) caught when processing request: Connection timed out
我去看了一下hadoop环境,原来是在做迁移,整个hadoop环境已经坏了。我的需求是:当hdfs文件系统挂了,读取不到文件的时候,往mysql中插入一条失败记录。但是请求在连接超时后,一直在尝试重新连接,从日志看出,一直要连接45次,于是百度了一下配置文件参数配置,设置:
Configuration conf = new Configuration();
//在连接超时后,客户端连接重试次数 conf.setInt("ipc.client.connect.max.retries.on.timeouts",1);
fs = FileSystem.get(URI.create(uri), conf);
然后捕获异常,成功在catch中插入记录到mysql。
注意要和客户端连接重试次数区分开:
客户端连接重试次数:
ipc.client.connect.max.retries=10
本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注编程语言JAVA频道!
喜欢 | 0
不喜欢 | 0
您输入的评论内容中包含违禁敏感词
我知道了

请输入正确的手机号码
请输入正确的验证码
您今天的短信下发次数太多了,明天再试试吧!
我们会在第一时间安排职业规划师联系您!
您也可以联系我们的职业规划师咨询:
版权所有 职坐标-一站式AI+学习就业服务平台 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
沪公网安备 31011502005948号