SET spark.driver.memory=32G;
SET spark.executor.memory=16G;
SET spark.dynamicAllocation.minExecutors=100;
shuffle fetch wait time is:xxx ms greater than max wait 1800000 ms, throw exception
原因: shuffle超时. 作业认为shuffle卡住, 故报错退出
解决方案: 如果作业shuffle时间不超过1800s, 请直接重试. 否则可以调整spark.shuffle.maxFetchWaitTime参数, 提高阈值(默认1800s).
SET spark.shuffle.maxFetchWaitTime=7200s
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)