Python 3.6でSparkSessionとSparkContextをどのように初期化するのですか？

Question

だから、私は次のコードを使用してのpython 3.6でSparkSessionとSparkContextを初期化しようとしています：

from pyspark.sql import SparkSession 
from pyspark import SparkContext 

#Create a Spark Session 
SpSession = SparkSession \ 
    .builder \ 
    .master("local[2]") \ 
    .appName("V2 Maestros") \ 
    .config("spark.executor.memory", "1g") \ 
    .config("spark.cores.max","2") \ 
    .config("spark.sql.warehouse.dir", "file:///c:/temp/spark-warehouse")\ 
    .getOrCreate() 

私はこれをしようと、次のエラー毎回取得：

module 'pyspark' has no attribute 'heapq3' 

を私に知らせてください私は間違っている。私はスパークするのはかなり新しいです。

Answer 1

私はPython 3.6に問題があると思います。 hereを参照してください。古いバージョンのPythonを使用することをお勧めします。問題が修正されてテストされたら、Pythonで使い始めることができます。3.6