stackoverflow.com/questions/45707205/...
у несколько сообщений, которые содержат ту же ошибку, что и ошибка, которую я получаю, но ни одна из них не приводит меня к исправлению моего кода. Я использовал этот же код много раз без проблем, и теперь у меня проблемы. Вот ошибка, которую я получаю:
y4j.protocol.Py4JJavaError: An error occurred while calling None.org.apache.spark.api.java.JavaSparkContext.
: org.apache.spark.SparkException: Only one SparkContext may be running in this JVM (see SPARK-2243).
Вот как я начинаю свой контекст в моем скрипте Python:
spark = ps.sql.SparkSession.builder \
.master("local[*]") \
.appName("collab_rec") \
.config("spark.mongodb.input.uri", "mongodb://127.0.0.1/bgg.game_commen$
.getOrCreate()
sc = spark.sparkContext
sc.setCheckpointDir('checkpoint/')
sqlContext = SQLContext(spark)
Пожалуйста, дайте мне знать, если у вас есть предложение.