开发者社区> 问答> 正文

flink 1.6 : TaskExecutor exceeded the idle timeout

flink 运行日志报:
org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_e59_1538204456867_1982674_01_000004 because: TaskExecutor exceeded the idle timeout.
2018-10-25 19:34:59,467 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 40060a189ff05c443c9149be6d234d27 from the SlotManager.
2018-10-25 19:34:59,472 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_e59_1538204456867_1982674_01_000010.
2018-10-25 19:34:59,473 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - Opening proxy : hadoop2256.jd.163.org:45454

搜了google,user mail 里提到:http://mail-archives.apache.org/mod_mbox/flink-user/201805.mbox/%3CCAO6dnLziL=CALygwuG8hu+fHv4psXixizmpsXUYNga_6QkHu6Q@mail.gmail.com%3E

貌似是flink 的bug ? 请阿里的大神帮忙看下

展开
收起
姚斌martin 2018-10-26 10:41:46 6376 0
1 条回答
写回答
取消 提交回答
  • @姚斌 你的场景里除了这个日志,有别的异常么?现在的逻辑里是可能会多申请资源的,但是过一段时间后多申请的资源会被释放(您发的日志就是释放多的资源),应该不影响正常job的执行

    2019-07-17 23:10:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Kafka and the Rise of Stream Processing 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载