无法在sparkversion 2.0.1中创建sparkcontext

Question

我最近把我的spark版本从1.5更新到2.0.1。按python脚本停止工作。在

1.5中的代码有效

sc=SparkContext(appName="YOGI")

spark 2.0.1中的代码修改

^{pr2}$

Answer 1

查看代码：

sc = SparkContext().master("spark://107.110.74.58:7077").appName("Python Spark SQL basic example").getOrCreate()

您应该尝试使用.setMaster而不是.master

Spark documents建议：

conf = SparkConf().setAppName(appName).setMaster(master)
sc = SparkContext(conf=conf)

对于您的情况，请尝试：

^{pr2}$

请注意，我已经删除了.getOrCreate()部分