diff --git a/data_prepare-0.py b/data_prepare-0.py index 5fb8fe9..0b99758 100644 --- a/data_prepare-0.py +++ b/data_prepare-0.py @@ -37,7 +37,7 @@ if __name__ == "__main__": conf = SparkConf().setMaster("spark://master:7077").setAppName("als_movie") #连接到Spark独立集群的主节点(Master),地址为master:7077;任务名als_movie -sc = SparkContext.getOrCreate(conf) + sc = SparkContext.getOrCreate(conf) sc.setLogLevel("ERROR") ratingsRDD, moviesRDD = init_rdds(sc)