开发者社区 > 大数据与机器学习 > 实时计算 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 16 0
1 条回答
写回答
取消 提交回答

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载
    http://www.vxiaotou.com