FlinkUnauthorized request to start container. This token is expired. current time is

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkUnauthorized request to start container. This token is expired. current time is相关的知识,希望对你有一定的参考价值。

1.概述

转载:https://blog.csdn.net/weixin_43970890/article/details/102483720

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 对这个问题进行了优化,一是在启动前增加了有效性检查,避免了无意义的配置上传流程,二是进行了异步多线程优化,加快启动速度。

以上是关于FlinkUnauthorized request to start container. This token is expired. current time is的主要内容,如果未能解决你的问题,请参考以下文章

request.getScheme() request.getServerName() request.getServerPort() request.getContextPath()(示例(代码

request.getParameter()request.getInputStream()和request.getReader()

request.getParameter() request.getInputStream()和request.getReader()三者的区别

Requests库入门

urllib.request.Request

Python爬虫 requests -- requests的安装和基本使用requests的get请求 / post请求requests ip代理