1.视界

2.背景

做kafka输出到多个sink，测试类：com.spark.test.sink.multiple.MultipleSinkSumUpdateTest#multipleSinkTest28
在这里，单测是没有问题的，但是在平台上测试报错

9/10/21 16:21:38 WARN server.TransportChannelHandler: Exception in connection from /192.168.xxx.xx:34744
java.io.IOException: Connection reset by peerat sun.nio.ch.FileDispatcherImpl.read0(Native Method)at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1106)at io.netty.channel.socket.nio.Ni

SparkStructured报错：Failed to send RPC xxx to /xxx:34744: ClosedChannelException Lost executor相关推荐

Spark报错 Failed to send RPC xxx to/ip:43074 java.nio.channels.ClosedChannelException
1.美图 2.背景是这样的,我写了一个spark程序,然后,运行的时候,我kiill yarn掉这个程序,然后发现程序报个错然后继续运行了. 我在页面点击任务停止就没事,我页面点击是调用yarn a ...
Arcgis Server 发布服务报错Failed to start the server machine ‘XXX‘. Error while starting AppServer. Requir
Arcgis Server 发布服务报错 Failed to start the server machine 'XXX'. Error while starting AppServer. Requi ...
搭建Consul报错Failed to start RPC layer: listen tcp XX.XXX.XXX.XXX:XXXX:: bind: cannot assign requested
搭建SprinfCloud-Consul报错解决方案搭建步骤 1.解压 2.在consul目录下创建conf.data/consulData文件夹 3.把basic.json文件放到conf目录. ...
搭建elsticsearch集群报错 failed to send join request to master [{data-node-0}(已经测试)
版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/qq_24879495/article/details/77718032 搭建elsticsea ...
【Flink】Flink 写入 kafka 报错 Failed to send data to Kafka: Expiring 4 record(s) for 20001 ms has passed
文章目录 1.场景1 1.1 概述 1.2 百度 1.3 同样问题 2.场景再现本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.场景1 1.1 概 ...
解决：ES报错failed to send join request to master
报错:failed to send join request to master [{hadoop103}{0N-QeaPVRT-iv54NU1nlqQ}{fhTrVKVVR3i3V0UcK1TCXg ...
【错误记录】Android Studio 配置 AspectJ 报错 ( Failed to create Jar file C:\xxx\aspectjtools-1.8.10.jar. )
文章目录一.报错信息二.解决方案三.Gradle 与 Gradle 插件版本适配一.报错信息在 Android Studio 中配置 AspectJ , 配置后的 Module 下的 bui ...
【Flink】flink Kafka报错 : Failed to send data to Kafka: This server is not the leader for that topic-pa
1.背景出现这个问题的背景请参考:[Kafka]Failed to send data to Kafka: Expiring 30 record(s) for xxx 732453 ms has p ...
git 本地项目关联线上仓库报错 failed to push some refs to “XXX”
报错信息执行 git remote add origin 仓库地址进行项目关联执行 git push -u origin master 步骤出现上面错误原因是:本地项目中缺乏线上的 READM ...
pom 文件的project标签报错Failed to read artifact descriptor for xxx:jar
今天从github上下载了感觉不错的项目(spring boot),使用idea导入的时候发现了一个问题,在这记录一下. 报错信息如下: 首先我想到的就是这个包应该是在仓库中能找到,但是由于未知原因没 ...

SparkStructured报错：Failed to send RPC xxx to /xxx:34744: ClosedChannelException Lost executor

1.视界

2.背景

SparkStructured报错：Failed to send RPC xxx to /xxx:34744: ClosedChannelException Lost executor相关推荐

最新文章

热门文章