Pyspark报错:Total size of serialized results is bigger than spark.driver.maxResultsSize
·
问题
如题
原因
spark.dirver.maxResultSize参数默认为1024兆,所以会有限制
解决方法
在python脚本最上面添加如下配置即可
from pyspark.sql import SparkSession
spark = SparkSession \
.builder \
.appName("Python Spark SQL basic example") \
.config("spark.memory.fraction", 0.8) \
.config("spark.executor.memory", "14g") \
.config("spark.driver.memory", "12g") \
.config("spark.sql.shuffle.partitions", "800") \
.config("spark.driver.maxResultSize", "0") \
.getOrCreate()
更多推荐
所有评论(0)