前回記載した、pysparkの環境構築時に実行する以下のコマンドでエラーが出るようになったので解決方法を備忘録として記載する。
spark = SparkSession.builder \
.master(“local[1]”) \
.appName(“knock”) \
.getOrCreate()
Py4JJavaError: An error occurred while calling None.org.apache.spark.api.java.JavaSparkContext.
: java.lang.UnsupportedOperationException: getSubject is supported only if a security manager is allowed...略
どうやらセキュリティ系のエラーで設定変更が必要らしい。
SparkSessionの作成時に以下のように設定を追加する
SparkSession.builder \
.master("local[1]") \
.appName("knok") \
.config("spark.driver.extraJavaOptions", "-Djava.security.manager=allow") \ # 追加部分
.config("spark.executor.extraJavaOptions", "-Djava.security.manager=allow") \ # 追加部分
.getOrCreate()