请大家帮忙看看下面出现的问题怎么解决呢?

org.apache.hadoop.security.token.SecretManager$InvalidToken: Invalid AMRMToken from appattempt_1676649102918_21781_000001这个错误?背景是公司集群有kerberos认证,然后flink是1.12版本,运行的时候报taskManager timeout自动重启后就报了这个错误,我搜了一下网上,看到有人报这个错误说是yarn-client问题,在2.7版本后就解决了。而我项目中用的是是2.7.7版本,而且点进去看了一下 3e5ca27b305b2d3cff05137634c6f8e.png,,发现是正确的。那么还有没有其他原因导致报这个错误?有没有谁碰到过呀?

展开
收起
JWRRR 2023-04-03 14:55:24 439 分享 版权
2 条回答
写回答
取消 提交回答
  • 您好,我也遇见了同样的问题,麻烦问下怎么解决的啊最后

    2023-08-15 15:41:28
    赞同 展开评论
  • 存在即是合理

    可能是由于Flink的YARN集成在使用Kerberos认证的集群中遇到了问题导致的。AMRMToken是一种YARN集群的令牌,如果Flink无法验证这个令牌,则会抛出org.apache.hadoop.security.token.SecretManager$InvalidToken异常。这个异常通常是由于Kerberos认证失败或Flink和YARN之间的令牌不匹配引起的。

    您提到的关于YARN-Client的问题和版本问题可能与您遇到的问题有关,因为早期版本的YARN可能存在与Kerberos认证相关的问题。

    2023-04-14 17:46:44
    赞同 展开评论

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

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理