在window上运行spark程序写到本地文件的时候报错。
val rdd = sc.sparkContext.parallelize(list)
val arr = rdd.collect()
arr.foreach(println)
rdd.saveAsTextFile("test1")
sc.close(
在window上运行spark程序写到本地文件的时候报错。
val rdd = sc.sparkContext.parallelize(list)
val arr = rdd.collect()
arr.foreach(println)
rdd.saveAsTextFile("test1")
sc.close(