Flink Cluster 常见问题之：TaskManager 启动异常是什么原因？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
org.apache.hadoop.yarn.exceptions.YarnException: Unauthorized request to start container. This token is expired. current time is ... found ... 该异常在 Flink AM 向 YARN NM 申请启动 token 已超时的 Container 时抛 出，通常原因是 Flink AM 从 YARN RM 收到这个 Container 很久之后（超过了 Container 有效时间，默认 10 分钟，该 Container 已经被释放）才去启动它，进一步原因是 Flink 内部在收到 YARN RM 返回的 Container 资源后串行启动。 当待启动的 Container 数量较多且分布式文件存储如 HDFS 性能较慢（启 动 前 需 上 传 TaskManager 配 置）时 Container 启 动 请 求 容 易 堆 积 在 内 部， FLINK-13184 对这个问题进行了优化，一是在启动前增加了有效性检查，避免了无 意义的配置上传流程，二是进行了异步多线程优化，加快启动速度。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
你好，我是AI助理
可以解答问题、推荐解决方案等
评论
全部评论 (0)