阿里云文档 2025-02-18

Checkpoint与Savepoint

系统检查点(Checkpoint)和作业快照(Savepoint)统称为状态集。本文为您介绍如何管理作业的状态集,包括创建、查看、删除和从指定状态恢复。

文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之mini-cluster模式下,怎么指定checkpoint的时间间隔

问题一:在Flink CDC项目中,我正在使用Flink PostgreSQL CDC功能是否支持断点续传? 在Flink CDC项目中,我正在使用Flink PostgreSQL CDC功能,想知道它是否支持断点续传(即从上次停止的位置恢复读取变更数据)。我已经设置了checkpoint,周期为3分钟,并且在每次checkpoint时保存了PostgreSQL CDC source的o...

实时计算 Flink版产品使用问题之mini-cluster模式下,怎么指定checkpoint的时间间隔
问答 2024-01-24 来自:开发者社区

Flink CDC里为什么使用yarn-session模式这样启用不了checkpoint吗?

Flink CDC里flink run -d -D yarn.application.id=application_xxxx -D execution.checkpointing.interval=60000,flink1.16版本为什么使用yarn-session模式这样启用不了checkpoint吗?

问答 2024-01-09 来自:开发者社区

Flink中appliction 模式怎么从 checkpoint 保存的地方 启动?

Flink中appliction 模式怎么从 checkpoint 保存的地方 启动?

问答 2023-09-13 来自:开发者社区

Flink sql batch模式能生成checkpoint吗?

Flink sql batch模式能生成checkpoint吗?我要计算一个累计数据,想用batch模式先跑一下,中间状态结果存在savepoint中,然后用streaming模式读取savepoint进行恢复继续跑任务,这个可以实现吗?

问答 2023-08-29 来自:开发者社区

大佬们,Flink CDC Standalone模式(3台机器)怎么设置checkpoint的位置?

大佬们,Flink CDC Standalone模式(3台机器)怎么设置checkpoint的位置,不依赖hdfs或者s3,有没有什么好的解决办法?

问答 2023-07-01 来自:开发者社区

各位大佬,Flink CDC中动态加表是不是要在全量模式的checkpoint下才能加啊?

各位大佬,Flink CDC中动态加表是不是要在全量模式的checkpoint下才能加啊?

问答 2023-06-29 来自:开发者社区

flink cdc initial 模式, source表数据量过大,导致checkpoint 一?

flink cdc initial 模式, source表数据量过大,导致checkpoint 一直 Checkpoint expired before completing. 有没有遇到过的大神指导一下如何优化呀?

问答 2023-04-05 来自:开发者社区

flink cdc initial 模式, source表数据量过大,导致checkpoint

flink cdc initial 模式, source表数据量过大,导致checkpoint 一直 Checkpoint expired before completing. 有没有遇到过的大神指导一下如何优化呀?

阿里云文档 2022-12-28

如何在Flink集群中配置OSS来存储Checkpoint和Savepoint

本文通过示例为您介绍如何在E-MapReduce on ACK的Flink集群中配置OSS来存储Flink作业的Checkpoint和Savepoint。

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等