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...

到底了