diff --git a/Aufgabe 5/sparkstart.py b/Aufgabe 5/sparkstart.py index bdb7010..6166989 100644 --- a/Aufgabe 5/sparkstart.py +++ b/Aufgabe 5/sparkstart.py @@ -10,7 +10,7 @@ from pyspark.sql import SparkSession # connect to cluster conf = SparkConf().setMaster("spark://193.174.205.250:7077").setAppName("HeisererValentin") conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer") -conf.set("spark.executor.memory", '32g') +conf.set("spark.executor.memory", '16g') conf.set("spark.driver.memory", '8g') conf.set("spark.cores.max", "40") scon = SparkContext(conf=conf)