简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
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...
到底了