MapReduce服务 MRS-由于Timeout waiting for task异常导致Shuffle FetchFailed:回答
回答
JD BCS erver方式使用了ShuffleService功能,Reduce阶段所有的Executor会从NodeManager中获取数据,当数据量达到一个级别(10T级别),会出现NodeManager单点瓶颈(ShuffleService服务在NodeManager进程中),就会出现某些Task获取数据超时,从而出现该问题。
因此,当数据量达到10T级别以上的Spark任务,建议用户关闭ShuffleService功能,即在“Spark-defaults.conf”配置文件中将配置项“spark.shuffle.service.enabled”配置为“false”。
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- 什么是Spark_如何使用Spark_Spark的功能是什么
- MapReduce服务_什么是Flink_如何使用Flink
- MapReduce服务_什么是Yarn_如何使用Yarn
- MapReduce服务_什么是Loader_如何使用Loader
- MRS备份恢复_MapReduce备份_数据备份
- 华为云CCE_华为云容器引擎CCE_容器高性能调度
- MapReduce服务_什么是MapReduce服务_什么是HBase
- 如何快速部署高可用七层负载均衡_七层负载均衡是什么意思_华为云七层负载均衡-华为云
- Hudi服务_什么是Hudi_如何使用Hudi