当前位置:   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')


声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/凡人多烦事01/article/detail/66426
推荐阅读
相关标签
  

闽ICP备14008679号