spark.executor.heartbeatInterval:10S
spark.executor.heartbeat.maxFailures:60次
Spark task run,返回driver最大上限:spark.driver.maxResultSize:1G
如果超过1G,结果会被抛弃。
直接内存返回时,结果需要小于Math.min(spark.task.maxDirectResultSize:1M,spark.rpc.message.maxSize:128M),也就是结果小于1M时,通过内存返回,否则通过block返回
见Executor.scala
网友评论