当前位置:   article > 正文

python 扩大spark.driver.maxResultSize参数_tasksetmanager: total size of serialized results o

tasksetmanager: total size of serialized results of 6162 tasks (1048.3 mb) i

spark默认的spark.driver.maxResultSize为1g,所以在运行spark程序的时候有时候会报错:

ERROR TaskSetManager: Total size of serialized results of 8113 tasks (1131.0 MB) is bigger than spark.driver.maxResultSize (1024.0 MB)

解决方案是:

from pyspark import SparkConf, SparkContext

SparkContext.setSystemProperty('spark.driver.maxResultSize', '10g')


本文内容由网友自发贡献,转载请注明出处:https://www.wpsshop.cn/w/凡人多烦事01/article/detail/66426
推荐阅读
相关标签
  

闽ICP备14008679号