logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

spark直连kafka中遇到的问题

出现问题:找不到 leader offsetpy4j.protocol.Py4JJavaError: An error occurred while calling o41.createDirectStreamWithoutMessageHandler.: org.apache.spark.SparkException: java.nio.channels.ClosedChannelExce...

ERROR:py4j.java_gateway:An error occurred while trying to connect to the Java server (127.0.0.1:5825

在用pyspark做数据处理时,经常遇到这样的坑在此作个记录:(1)配置文件:当字段数太多时,需要配置字段数长度,注意其中的数字是字符串,不然会报错。ERROR:py4j.java_gateway:An error occurred while trying to connect to the Java server (127.0.0.1:5825错误代码如下:spark...

到底了