spark消费kafka数据报错 Queries with streaming sources must be executed with writeStream.start();

spark消费kafka数据报错 Queries with streaming sources must be executed with writeStream.start();,第1张

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

原因是:只调用.start()了一个悬空没有终止,这反过来又抛出了你回来的异常。
解决方案是启动两个分支并等待终止。

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5656473.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存