分享 用sparkStreaming实时做wordCount出现的错误
boge3355 2020-11-5 11:03
object SparkStreamingWordCount { def main(args: Array ): Unit = { //离线任务是创建SparkContext,现在要实现实时计算,用StreamingContext val conf = new SparkConf().setAppName("SparkStreamingWordCount").setMaster("local ") val sc = new S ...
个人分类: sparkStreaming程序出现的错误记录|567 次阅读|0 个评论
关闭

推荐上一条 /2 下一条