【Spark】報錯：Only one SparkContext may be running in this JVM (see SPARK-2243).

報錯

分析

object partOne1 {

  // 建立環境
  val conf = new SparkConf()
    .setAppName("hdfs")
    .setMaster("local[6]")
  val sc = new SparkContext(conf)
  // 設定日志級别
  sc.setLogLevel("ERROR")

  def main(args: Array[String]): Unit = {

    // 建立環境
    val conf = new SparkConf().setMaster("local[6]").setAppName("HDFS")
    val sc = new SparkContext(conf)

    // hdfs讀取資料
    val hdfs = sc.textFile("hdfs://192.168.64.178:9000/spark/zhaopin.csv")
    // 展示資料集
    hdfs.foreach(println(_))

}