开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink Cluster 常见问题之:TaskManager 启动异常是什么原因?

Flink Cluster 常见问题之:TaskManager 启动异常是什么原因?

展开
收起
Lee_tianbai 2020-12-30 13:34:29 1466 0
1 条回答
写回答
取消 提交回答
  • 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 对这个问题进行了优化,一是在启动前增加了有效性检查,避免了无 意义的配置上传流程,二是进行了异步多线程优化,加快启动速度。

    2020-12-30 13:34:51
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载