spark stream的network_wordcount.py执行报错

来源:9-5 -从词频统计案例来了解SparkStreaming

jamko

2020-06-26

老师,我的电脑是macbook,课程9-5 spark stream执行$ ./bin/spark-submit examples/src/main/python/streaming/network_wordcount.py localhost 9999的时候,报错:
RuntimeError: generator raised StopIteration
2020-06-26 01:25:17 WARN SocketReceiver:87 - Error receiving data
java.net.SocketException: Socket closed
我的Netcat启动是正常的:
JAMXIE-MB0:sbin xieyuanzheng$ nc -lk 9999
hello word
hello
请问,您知道是什么原因吗?我上网找不到相关解决办法,并且我是按源码执行,难道是我的本地PC要配置什么,或者要启动什么进程吗?

写回答

1回答

Michael_PK

2020-06-26

你这个py文件本地测试能跑通吗

0
2
Michael_PK
回复
jamko
哈哈哈哈。找到问题就好。个人建议哈,在第一次学习的时候尽量和上课的环境一致,这样可以规避掉不少问题。学完之后有兴趣的话可以再来升级对应的软件的版本
2020-06-27
共2条回复

Python3实战Spark大数据分析及调度

使用Python3对Spark应用程序进行开发调优,掌握Azkaban任务调度

1046 学习 · 434 问题

查看课程