在使用阿里云的Java SDK从阿里云的对象存储服务(OSS)中使用数据时,出现“SSL peer错误关闭”异常。我们使用的是Oracle Java8.x、Hadoop3.x。我们在作为Oozie工作流运行时得到了这个异常,并将数据persit到HDFS路径中。如何解决这个问题?
// Create an OSSClient instance.
ClientBuilderConfiguration clientConfig = new ClientBuilderConfiguration();
clientConfig.setProxyHost(PROXY_HOST);
clientConfig.setProxyPort(PROXY_PORT);
clientConfig.setProtocol(Protocol.HTTPS);
OSS ossClient = new OSSClientBuilder().build(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET, clientConfig);
String fileKey = "4868a87eb2a0f7a06c43";
OSSObject ossObject = ossClient.getObject(BUCKET_NAME, fileKey);
InputStream objectContent = ossObject.getObjectContent();
try (InputStream inputStream = objectContent) {
copyInputStreamToFile(inputStream, targetFile);
}
Failing Oozie Launcher, Main class [org.apache.oozie.action.hadoop.JavaMain], main() threw exception, javax.net.ssl.SSLException: SSL peer shut down incorrectly
org.apache.oozie.action.hadoop.JavaMainException: javax.net.ssl.SSLException: SSL peer shut down incorrectly
...
Caused by: javax.net.ssl.SSLException: SSL peer shut down incorrectly
at sun.security.ssl.InputRecord.readV3Record(InputRecord.java:596)
at sun.security.ssl.InputRecord.read(InputRecord.java:532)
at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:975)
at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:933)
at sun.security.ssl.AppInputStream.read(AppInputStream.java:105)
at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:139)
at org.apache.http.impl.io.SessionInputBufferImpl.read(SessionInputBufferImpl.java:200)
at org.apache.http.impl.io.ContentLengthInputStream.read(ContentLengthInputStream.java:178)
at org.apache.http.conn.EofSensorInputStream.read(EofSensorInputStream.java:137)
at java.util.zip.CheckedInputStream.read(CheckedInputStream.java:82)
at java.io.FilterInputStream.read(FilterInputStream.java:133)
at com.aliyun.oss.event.ProgressInputStream.read(ProgressInputStream.java:116)
at java.util.zip.CheckedInputStream.read(CheckedInputStream.java:82)
at java.io.FilterInputStream.read(FilterInputStream.java:107)
at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:100)
at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:68)
at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:129)
你每次都是随机的还是一致的?您没有为人们提供足够的信息来帮助您。到目前为止,你尝试过哪些解决方案?
此错误消息SSL对等点关闭错误
是一条一般消息,可能由多种原因造成。我建议你通读这篇文章,然后一篇一篇地尝试。
尝试检查远程SSL证书,验证其有效性,很可能问题就在那里。
打开-djavax.net.debug=ssl,握手
要求您对握手过程有一定程度的了解,有时这可能很困难。您可以使用mitmproxy之类的工具来检查https通信量。
您也可以使用联机TLS检查器检查TLS支持。
双非本科,参加了无数场面试,以下是最近面阿里的总结(来源于网络): 阿里 面经1 简单介绍项目 知道哪些数据结构以及他们的特点 链表增删快,那如何提高其查询效率,有没有什么想法? B+树了解吗?B+树如何范围查询?B+树退化的极端情况是什么? 跳表了解吗? 大顶堆、小顶堆了解吗? 实现长地址请求到服务端,然后服务端重定向短地址给客户端,如何实现长短地址的互相映射? 那我现在有10份数据,有1000
如果我在以下URL上运行上述代码:https://eztv.it/shows/887/the-blacklist/,它将按预期工作。两个URL文件大小之间的差异似乎是一个促成因素。在测试同一个服务器的不同URL时,上面的代码似乎只适用于小于30KB的文件。以上任何内容都将生成上述异常。
吹爆阿里,整个面试过程体验极佳! 数据库怎么分类,描述一下你对这些数据库的理解 什么情况使用MySQL,什么情况使用Redis Redis有什么持久化策略 MySQL有哪2种引擎,说一下它们的区别 MySQL两个线程的update语句同时处理一条数据,会不会有阻塞 滥用事务,或者一个事务里有特别多sql的弊端 两条update语句处理一张表的不同的主键范围的记录,一个<10,一个>15,会不会遇到
#产品2023笔面经# 去年投简历直接挂 今年投终于收到了笔试 北森题库 40min 10言语理解 10资料分析 10图形推理 51性格测试 形式上和携程、shein的一致,只是性格测评不太一样,求一个面试机会吧
这次是被调岗加面一轮,由于自己的身体状况原因,中间歇了一段时间没有面试,发现距离上次面试已经过去大半个月了。 1.自我介绍 2.介绍一下上段实习主要做什么的,并且进行深挖 3.介绍一下上上段实习是干嘛的,通过什么模型之类的进行工作 4.你觉得你碰到最有挑战的工作是什么 5.为什么投了阿里 6.还投了什么其他公司,并追问为什么没去呢 我:因为没过面试 7.那你觉得面试为什么会没通过 8.读书和工作期
饿了么的数据研发岗位,整体面试体验很好!记录一下我的面(凉)经和反思吧~ 8-9 投递 8-13 行测+性格 8-21 笔试,15选择题,3个编程,我分别是100,90,6 8-25 一面 面试官先自我介绍,然后说大概全程30分钟,然后让我自我介绍。接着问更倾向于做算法还是做开发。有没有大数据,数据开发相关的经验,或者课。 接着问sql常用语句,优化方法。 数据结构相关,排序算法。 手撕代码:两个