出現這個問題一般是未找到本地上的Hadoop路徑,環境變數沒有配置或者是沒有下載hadoop環境,
解決方法:
1.去官網下載自己需要的hadoop版本:
http://archive.apache.org/dist/hadoop/
下載完后解壓到指定的目錄之下記住目錄名字,
2.下載相對應的hadoop-common
https://download.csdn.net/download/master_hunter/16530725
將其中的
放入原來hadoop的bin目錄下
3.編輯環境變數
添加HADOOP_HOME

若沒有則新建一個,
添加CLASSPATH
%HADOOP_HOME%\bin\winutils.exe

添加PATH
%HADOOP_HOME%\bin;

4.測驗
import org.apache.spark.{SparkConf, SparkContext}
object test {
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("Spark pi").setMaster("local")
val sc = new SparkContext(conf)
val data = sc.parallelize(1 to 10)
data.foreach(println(_))
}
}
跑一跑或者:

成功
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/273692.html
標籤:其他
