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

请问大家有遇到过Flink Standlone，Job失败后TaskSlot无法回收的问题吗？这个回

请问大家有遇到过Flink Standlone，Job失败后TaskSlot无法回收的问题吗？这个回收机制是怎么样的呢？

展开
收起
游客3oewgrzrf6o5c 2022-07-22 12:08:41 267 分享 版权

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

1 条回答
写回答
取消 提交回答
  • bbskkb
    阿里云大学导师

    回收机制如下：

    非托管模式：在非托管模式下，Flink 会直接关闭 TaskManager 上与失败 Job 相关的 Task Slot，以便将资源返还给集群。

    托管模式：在托管模式下，Flink 会向 JobManager 发送消息，通知它失败的 Job 需要回收其使用的 Task Slot。JobManager 会相应地通过调度器将这些 Task Slot 标记为空闲状态，以备其他作业使用。

    需要注意的是，Task Slot 的回收可能不会立即发生，而是会在一段时间后进行。具体延迟取决于 Flink 的配置和调度策略。Flink 通常会在某个时间窗口内检查失败 Job 的状态，并回收相应的 Task Slot。

    2023-07-24 14:46:44
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版job 实时计算 Flink版回收 实时计算 Flink版job回收 实时计算 Flink版 job
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
Flink CDC里有没有大神知道为什么 jvm metaspace 不会自动回收啊？
267
2
0
Flink CDC任务取消后，这里jvm metaspace不回收为什么？
261
3
0
哪个配置是设置Flink CDC内存回收的 占用的内存越来越大？
74
1
0
Flink CDC里jobManager的内存 每提交一次job 就会涨一次，不会回收怎么办？
85
1
0
Flink on yarn 的taskslot为0呢？
359
2
0
flink-cdc pg支持多并发启动 然后变为增量后并发度变为1，其他slot回收 吗？
47
3
0
flink standalone模式，jobmanager无法回收fail的任务，这个怎么解决的?
128
2
0
Flink CDC这个Managed Memory不得自动回收吗？
76
1
0
flink用adb pg作为结果表，报错，显示超时，要开启回收机制吗？
97
2
0
老板们，遇到过Flink CDC 这个问题吗。不回收 mysql cdc的，几分钟干满6G内存。
107
0
0
大数据与机器学习

实时计算 Flink

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

我要提问
收录在圈子:
阿里云实时计算Flink
199210
+ 订阅
实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

相关文章

  • Flink CDC + Hologres高性能数据同步优化实践
  • vivo基于Paimon的湖仓一体落地实践
  • 掌握大数据时代的心跳：实时数据处理的崛起
  • 基于Flink CDC 开发，支持Web-UI的实时KingBase 连接器，三大模式无缝切换，效率翻倍！
  • 官宣 | Fluss 0.6 发布公告

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
  • flink cdc 有没得官方介绍文档？
  • FlinkKafkaConsumer 1.11的clientId什么的看不到这个怎么解决吗？
  • flink大作业启动频繁报akka.pattern.AskTimeoutException 大家有
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
  • web-ui 加载会非常慢是什么原因呢？
  • flinkcdc启动，怎么修改默认端口号，默认是8081。
  • 在Flink为什么遇到这个报错后，作业虽然RUNNING，但是却HANG死了？会有什么隐形的坑吗？
  • 请教下，finksql 这个statettl 哪里设置
    • 展开全部
  • 数据仓库介绍与实时数仓案例
  • 权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
  • 分布式Snapshot和Flink Checkpointing简介
  • Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
  • 阿里云实时计算产品案例&解决方案汇总
  • 流计算精品翻译: The Dataflow Model
  • Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现
  • 为什么说流处理即未来？
  • Flink Checkpoint 问题排查实用指南
    • 展开全部
    还有其他疑问?
    咨询AI助理