2019-06-17
阅读量:
888
运行spark流计算程序报错
代码如下

报错信息如下:

这是什么原因?
答:结合代码与报错信息,发现是由于创建streamingDF时load()方法传入的参数有误导致的。这个位置需要传输一个文件目录,而不是某个文件,spark会自动的从该文件夹中读取各个文件信息。
0.0000
0
1
关注作者
收藏
评论(0)
发表评论
暂无数据
推荐帖子
0条评论
0条评论

