AI 助理
备案控制台
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请教一个K8S上部署的flink集群的问题？

请教一个K8S上部署的flink集群的问题？taskmanager运行一段时间pod就会error，报错日志是
2023-12-26 03:43:06,179 ERROR org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Fatal error occurred in TaskExecutor akka.tcp://flink@100.73.193.232:6122/user/rpc/taskmanager_0.
org.apache.flink.util.FlinkException: The TaskExecutor's registration at the ResourceManager akka.tcp://flink@100.65.6.181:6123/user/rpc/resourcemanager_0 has been rejected: Rejected TaskExecutor registration at the ResourceManger because: The ResourceManager does not recognize this TaskExecutor.
at org.apache.flink.runtime.taskexecutor.TaskExecutor$ResourceManagerRegistrationListener.onRegistrationRejection(TaskExecutor.java:2254) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutor$ResourceManagerRegistrationListener.onRegistrationRejection(TaskExecutor.java:2209) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.onRegistrationRejection(TaskExecutorToResourceManagerConnection.java:109) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.onRegistrationRejection(TaskExecutorToResourceManagerConnection.java:40) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.registration.RegisteredRpcConnection.lambda$createNewRegistration$0(RegisteredRpcConnection.java:269) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_312]
at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_312]
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456) ~[?:1.8.0_312]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.11-1.13.5.jar:1.13.5]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.11-1.13.5.jar:1.13.5]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) [flink-dist_2.11-1.13.5.jar:1.13.5]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.5.jar:1.13.5]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.5.jar:1.13.5]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.5.jar:1.13.5]
2023-12-26 03:43:06,202 ERROR org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - Fatal error occurred while executing the TaskManager. Shutting it down...
org.apache.flink.util.FlinkException: The TaskExecutor's registration at the ResourceManager akka.tcp://flink@100.65.6.181:6123/user/rpc/resourcemanager_0 has been rejected: Rejected TaskExecutor registration at the ResourceManger because: The ResourceManager does not recognize this TaskExecutor.
at org.apache.flink.runtime.taskexecutor.TaskExecutor$ResourceManagerRegistrationListener.onRegistrationRejection(TaskExecutor.java:2254) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutor$ResourceManagerRegistrationListener.onRegistrationRejection(TaskExecutor.java:2209) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.onRegistrationRejection(TaskExecutorToResourceManagerConnection.java:109) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.onRegistrationRejection(TaskExecutorToResourceManagerConnection.java:40) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at org.apache.flink.runtime.registration.RegisteredRpcConnection.lambda$createNewRegistration$0(RegisteredRpcConnection.java:269) ~[flink-dist_2.11-1.13.5.jar:1.13.5]
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) ~[?:1.8.0_312]
at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) ~[?:1.8.0_312]
然后jobmanager中没有报错，只是有拒绝的提示
flink--kubernetes-session-0-flink-cluster-5689c66d9c-92492.log:2023-12-26 03:43:06,114 WARN org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Discard registration from TaskExecutor flink-cluster-taskmanager-2-4 at (akka.tcp://flink@100.73.193.219:6122/user/rpc/taskmanager_0) because the framework did not recognize it
每次出现这种错误，需要人工干预手动重启jobmanager才能解决，不然任务就不运行了。

展开
收起
真的很搞笑 2024-01-04 12:16:09 261 0
3 条回答
写回答
取消 提交回答
  • sunrr

    这个错误表明TaskExecutor试图向ResourceManager注册，但ResourceManager拒绝了这次注册，因为它不认识这个TaskExecutor。这可能是因为TaskExecutor的配置不正确，或者是因为ResourceManager的配置不正确。

    以下是一些可能的解决方案：

    1. 检查TaskExecutor和ResourceManager的配置，确保它们的地址和端口正确无误。

    2. 检查Kubernetes的服务（Service）配置，确保TaskExecutor和ResourceManager能够通过服务名称互相找到对方。

    3. 如果可能，尝试重启TaskExecutor和ResourceManager，看看问题是否解决。

    4. 如果问题仍然存在，可能需要查看更详细的日志信息，以确定问题的具体原因。

    希望这些信息对你有所帮助！

    2024-01-05 16:18:54
    赞同 展开评论 打赏
  • 小周sir
    面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。

    根据您提供的错误日志，问题可能是由于TaskManager在ResourceManager中无法识别导致的。为了解决这个问题，您可以尝试以下方法：

    1. 检查TaskManager和ResourceManager之间的网络连接是否正常。确保它们可以互相通信。

    2. 检查TaskManager的配置文件（如flink-conf.yaml），确保其中的taskmanager.rpc.address和resourcemanager.rpc.address设置正确。这些地址应该与ResourceManager的地址相匹配。

    3. 检查Kubernetes集群中的Service资源，确保它们的名称和标签与TaskManager和ResourceManager的配置相匹配。例如，TaskManager的Service名称应该是flink-cluster-taskmanager-<taskmanager-id>，而ResourceManager的Service名称应该是flink-cluster-resourcemanager。

    4. 如果问题仍然存在，您可以尝试升级Flink和Kubernetes集群到最新版本，以确保兼容性和稳定性。

    5. 如果以上方法都无法解决问题，您可以考虑在Flink社区或相关论坛寻求帮助，提供更多关于您的环境和配置的详细信息。

    2024-01-04 16:49:20
    赞同 展开评论 打赏
  • 芯在这

    重启了吧，因为某些原因重启了 然后没有注册到flink集群中 bb983a5b80229711b33daaeb23885a25.png
    https://blog.csdn.net/qq_21383435/article/details/123262747 ，此回答整理自钉群“【②群】Apache Flink China社区”

    2024-01-04 13:04:25
    赞同 展开评论 打赏
问答分类：
流计算 容器 Kubernetes Perl 容器服务Kubernetes版 实时计算 Flink版 日志服务
问答标签：
实时计算 Flink版集群 容器服务Kubernetes版部署 容器服务Kubernetes版集群 实时计算 Flink版部署 实时计算 Flink版k8s
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关产品：
实时计算 Flink版

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答
实时计算 Flink版
请问各位大佬，有 flink-sql 跑 K8S中 Per-Job 模式 的么？
22
0
0
在Flink CDC中，cdc3.1.1是不是只能yarn session模式，官网部署模式？
62
1
0
美团 Flink 如何优化大作业的部署流程？
49
1
0
在美团 Flink 的大作业部署流程中，哪些环节对部署时间有显著影响？
33
1
0
K8S部署的Flink如何配JobManager和TaskManager的日志？
65
0
0
实时计算Flink版支持私有化部署吗？
38
0
0
有人用户 flink on k8s 吗？ 怎么解决的看日志的啊？
30
0
0
ARMS中我想使用阿里云的Prometheus这个，自建的k8s集群支持吗？
1124
1
0
本地k8s 集群如何部署基础版SREWorks？
1008
1
0
标准k8s 集群如何部署数智版SREWorks？
938
1
0
大数据与机器学习

实时计算 Flink

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

我要提问

相关产品

  • 实时计算 Flink版
    文档详情 产品详情

    • 热门讨论

    热门文章

  • 请问Flink 写数据到 ES 有遇到过这个报错的么？
    2153
  • FFA 2024 大会门票免费送！AI时代下大数据技术未来路在何方？
    1730
  • flink1.20.0 部署后发布报错，是怎么回事，各种配置都配置了
    344
  • Flink sql 累计历史订单金额
    170
  • Flink如何配置Task Manager？
    720
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    3627
  • 大佬们，有遇到flink on k8s，访问ui界面 log接口报500吗？
    330
  • flink本地启动webUI，TaskManager的Logs日志可以正常查看怎么办？
    513
  • 请问如何用flink sql客户端用yarn application模式提交任务呢？
    1576
  • 请问flink-connector-jdbc在sink时，如何设置批量写入？
    3198
    • 展开全部
  • 数据仓库介绍与实时数仓案例
    42429
  • 权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
    24499
  • OPPO数据中台之基石：基于Flink SQL构建实数据仓库
    21939
  • Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
    27989
  • 通过Flink实时构建搜索引擎的索引
    17471
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
    23425
  • 阿里云实时计算产品案例&解决方案汇总
    27925
  • Apache Flink 的迁移之路，2 年处理效果提升 5 倍
    9748
  • 基于实时计算（Flink）打造一个简单的实时推荐系统
    14433
  • Flink Checkpoint 问题排查实用指南
    13230
    • 展开全部

    相关课程

    更多
  • 大数据Flink实时旅游平台环境篇 2020版
    609
    29
    去学习
  • Serverless 容器从入门到精通: - Serverless Kubernetes
    1299
    7
    去学习
  • Apache Flink 入门到实战 - Flink开源社区出品
    1637
    16
    去学习
  • 实时计算 Flink 版产品入门与实操
    4026
    10
    去学习
  • Kubernetes云原生管理实践
    908
    3
    去学习
  • Kubernetes入门
    3734
    12
    去学习

    • 相关文章

  • 将基于 Spring 的 WAR 应用程序部署到 Docker：详尽指南
  • R 语言教程 之 R 数据类型 6
  • 深度探索Spring Context：框架式的Bean访问与企业级功能
  • 数仓质量监控方案
  • 【Azure ADLS】为Azure Data Lake Storage的Container赋予了操作权限后创建子文件夹遇见403报错

    • 相关电子书

    更多
    • ACK 云原生弹性方案—云原生时代的加速器 立即下载
    ACK集群类型选择最佳实践 立即下载
    企业运维之云原生和Kubernetes 实战 立即下载

    相关实验场景

    更多
  • 在ACK Serverless中部署Stable Diffusion应用
    200
    1.0小时
    去实验
  • 基于Hologres+Flink搭建GitHub实时数据大屏
    160
    1.0小时
    去实验
  • 基于Flink+Tair搭建实时监控大屏
    165
    1.0小时
    去实验
  • 使用ACK Serverless容器化部署大语言模型FastChat
    337
    1.0小时
    去实验
  • 5分钟上手Flink MySQL连接器
    444
    1.0小时
    去实验
  • 通过EDAS实现K8s微服务应用的金丝雀发布
    173
    1.0小时
    去实验

    • 相关镜像

  • kubernetes
  • pouch
  • docker-ce