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

Flink CDC里为啥cp会被删除呢？

Flink CDC里为啥cp会被删除呢？2a7c0babcabe9b72e832909fc1b24f80.png新建pod之后。a7033468bd141a6c7e7569e64f31584d.png我的flink pod delete掉后，cp 没有了，这是为啥呀？那我还怎么从cp重启哦？ # 快照文件不做删除
env.get_checkpoint_config(). \
set_externalized_checkpoint_cleanup(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION)---这个玩意来配置得13c31932c3b1c6c071e9b98aa36b35bd.png这种情况，把红的并行度增加，应该可以加快速度吧。 # 快照文件不做删除
env.get_checkpoint_config(). \
set_externalized_checkpoint_cleanup(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION)---这个东东有全局的配置么？

展开
收起
小小鹿鹿鹿 2024-05-07 18:46:05 15 0
1 条回答
写回答
取消 提交回答
  • 小小杳杳杳

    pod删了，ckp如果保存的不是远程地址被删除是正常的。一般都是存对象服务里面。mysql的普通实例写入能力是有限的，你再加东西也不见得能变快。此回答来自钉群Flink CDC 社区。

    2024-05-07 19:15:36
    赞同 1 展开评论 打赏
问答分类：
流计算 Perl 实时计算 Flink版
问答标签：
实时计算 Flink版CDC 实时计算 Flink版cp
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

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

相关问答
大家Flink的cp时间都给的是多少？
18
1
0
Flink CDC这个大家有什么办法不cp，让数据可见？
36
2
0
Flink的这个job 一直CP失败，什么原因？
7
0
0
flink cdc任务，突然断点的情况，flink重启后，任务还可以从cp重启的吗？
27
1
0
请问一个Flink单独的 Task 的 Pod 被删除后，它为什么不从最近的cp点读取状态数据？
17
0
0
Flink将StateBackend和CP从HDFS转换到容器绑定挂载的NAS性能怎么样吗？
15
0
0
各位大佬，用flink sql api写的程序打成jar包 java -cp方式运行有人成功过吗？
94
1
0
大佬,Flink CDC可不可以在从sp,或是cp恢复的时候重新读取下元数据,这个新增字段的时候就？
187
12
0
Flink CDC中sqlservercdc 2.2.1一使用cp启动就死锁 是怎么回事？
100
2
0
哪位了解Flink共享状态注册器吗？ 发现每次cp会返回一些数据给JM导致JM的内存较大
134
0
0
大数据与机器学习

实时计算 Flink

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

我要提问

热门讨论

热门文章

  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    1830
  • flink1.15启动后无法访问webui的问题有人遇到过吗
    9824
  • Flink CDC有遇见这个问题的吗？
    495
  • Flink这个未授权访问漏洞有什么解决方案吗？
    510
  • 阿里云实时计算的资源单位是什么？
    3636
  • Caused by: org.apache.kafka.common.errors.TimeoutE
    2241
  • flink怎么能够快速消费kafka数据，需要设置什么参数呢？
    320
  • yarn集群资源是充足的，为什么提交任务失败呢
    742
  • Flink sql将数组炸开，实现hive的explode函数的效果，还有什么其他好的方式？
    424
  • "flink-cdc-connector-mysql，这个报错怎么解决的？
    1264
    • 展开全部
  • 数据仓库介绍与实时数仓案例
    40227
  • 权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
    22160
  • 分布式Snapshot和Flink Checkpointing简介
    18974
  • Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
    26213
  • 流计算StreamCompute
    18154
  • 通过Flink实时构建搜索引擎的索引
    16803
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
    21523
  • 阿里云实时计算产品案例&解决方案汇总
    25094
  • 为什么说流处理即未来？
    9794
  • 广告场景下的实时计算
    10910
    • 展开全部

    相关课程

    更多
  • 实时计算 Flink 版产品入门与实操
    3806
    10
    去学习
  • 开源 Flink 极速上手教程
    1752
    7
    去学习
  • 大数据实时计算框架Spark快速入门
    778
    93
    去学习
  • Apache Flink 入门
    4826
    9
    去学习

    • 相关文章

  • 实时计算 Flink版操作报错合集之遇到报错："An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to ensure consistency." ，该怎么办
  • 实时计算 Flink版操作报错合集之写入 Kafka 报错 "Failed to send data to Kafka: Failed to allocate memory within the configured max blocking time 60000 ms"，该怎么解决
  • 实时计算 Flink版操作报错合集之在连接Oracle 19c时报错如何解决
  • 实时计算 Flink版操作报错合集之报错显示“Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE"是什么意思
  • 实时计算 Flink版操作报错合集之本地打成jar包，运行报错，idea运行不报错，是什么导致的

    • 相关电子书

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

    相关实验场景

    更多
  • 使用PolarDB-X与Flink搭建实时数据大屏
    188
    1.0小时
    去实验
  • 使用Flink实时发现最热Github项目
    861
    1.0小时
    去实验
  • 5分钟上手Flink MySQL连接器
    237
    1.0小时
    去实验
  • 基于Flink+Tair搭建实时监控大屏
    40
    1.0小时
    去实验
  • 基于Hologres+Flink搭建GitHub实时数据大屏
    50
    1.0小时
    去实验