赞
踩
本地模式遇到这个问题的原因:没有设置“local”本地模式。
解决办法:
// 设置spark运行环境,setMaster(“local”)本地模式,setAppName(“WordCount”)设置任务名为:WordCount
val sparkConf = new SparkConf().setMaster("local").setAppName("WordCount")
// 将设置的环境变量放入连接中
val sc = new SparkContext(config = sparkConf)
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。