热线电话:13121318867

登录
2019-06-17 阅读量: 780
运行spark流计算程序报错

代码如下

报错信息如下:

这是什么原因?

答:结合代码与报错信息,发现是由于创建streamingDF时load()方法传入的参数有误导致的。这个位置需要传输一个文件目录,而不是某个文件,spark会自动的从该文件夹中读取各个文件信息。

0.0000
1
关注作者
收藏
评论(0)

发表评论

暂无数据
推荐帖子