最后这样设置可以了 val conf = new SparkConf().setAppName(appName).setMaster("local[2]")
之前的是 val conf = new SparkConf().setAppName(appName).setMaster("spark://*.*.*.*:7077")
但是不明白为什么直接指定master的ip不可以
最后这样设置可以了 val conf = new SparkConf().setAppName(appName).setMaster("local[2]")
之前的是 val conf = new SparkConf().setAppName(appName).setMaster("spark://*.*.*.*:7077")
但是不明白为什么直接指定master的ip不可以