我试图增加pyspark配置中的心跳间隔参数,但一直得到此错误。是否存在spark.executor.heartbeatInterval
间隔和spark.network.timeout
的良好组合,增加了大作业的超时值,但也使我启动spark会话而没有此错误?
IllegalArgumentException: u'requirement failed: valueSpark.network.timeout =120s必须大于等于spark.executor.heartbeatInterval = 10000年代。
谢谢!
您还必须增加spark.network.timeout
值。
文档清楚地说明:
spark.executor.heartbeatInterval
应显著小于spark.network.timeout
很难解释;但默认情况下,spark.network.timeout
比spark.executor.heartbeatInterval
大12倍(120秒)。
试题:
--conf spark.network.timeout 100000 --conf spark.executor.heartbeatInterval 10000