spark消费kafka数据报错 Queries with streaming sources must be executed with writeStream.start();
有3年没有写spark了一切都是这么陌生MD. 今天跑下还报错,解决参考:https://stackoverflow.com/questions/40609771/queries-with-streaming-sources-must-be-executed-with-writestream-start
·
有3年没有写spark了一切都是这么陌生MD. 今天跑下还报错,
解决参考:
https://stackoverflow.com/questions/40609771/queries-with-streaming-sources-must-be-executed-with-writestream-start
原因是:只调用.start()了一个悬空没有终止,这反过来又抛出了你回来的异常。
解决方案是启动两个分支并等待终止。
更多推荐
已为社区贡献2条内容
所有评论(0)