zoukankan      html  css  js  c++  java
  • MapReduce设置参数防止超时

    1. 如果碰到异常“Task attempt failed to report status for xxx seconds. Killing!”,最可能是碰到死循环了。

    2. 如果没有死循环:控制超时的属性是:mapred.task.timeout,默认600000ms,即600s。可以设置成更大的值。可以直接在Jobconf或Configuration中修改(只对本Job起作用),也可以修改mapred-site.xml(对所有Job起作用)。

    3. 如果没有死循环,但task执行时间长又不好确定,可以在Reducer或Mapper中主动发送心跳,但需控制发送心跳的频率:

        long heartBeatInterval = 100000L;            //主动发心跳的间隔,100s,默认600s超时
        long lastProgressTS = 0;                     //上一次发心跳的时间点
            
        //主动发心跳
        if (System.currentTimeMillis() - lastProgressTS > heartBeatInterval) {
            context.progress();
            lastProgressTS = System.currentTimeMillis();
        }

    4. 再次,如果对自己的程序有信心不会出现死循环,可以采用更简单的办法:

    conf.set("mapred.task.timeout", "0");                        //不检查超时
  • 相关阅读:
    常见正则总结
    word 操作教程
    word调整技巧
    关于如何自定义handler
    html 处理
    iis 导入和导出配置——iis管理
    前端学习
    动态添加js的方法
    jquery学习笔记
    php学习笔记
  • 原文地址:https://www.cnblogs.com/aprilrain/p/2944400.html
Copyright © 2011-2022 走看看