问答 2024-07-31 来自:开发者社区

使用Flink cdc 任务的检查点设置为增量的,看checkpoint确实是一增量的方式在保存吗?

使用Flink cdc 然后任务的检查点设置为增量的,但是好像没有效果。同样的配置,对kafka任务确是有用的,能看到checkpoint确实是一增量的方式在保存吗?

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之通过设置什么可以自动清理旧的checkpoint数据

问题一:Flink CDC中operator如何设置自动清理旧的checkpoint数据呢? Flink CDC中operator如何设置自动清理旧的checkpoint数据呢?因为我的sql融合了很多表状态数据很大,但是看checkpoints有很多旧的,如何配置flink operator自动清理呢?streampark好用吗?感觉国内主导的很难稳定 参考...

实时计算 Flink版产品使用问题之通过设置什么可以自动清理旧的checkpoint数据
问答 2024-06-03 来自:开发者社区

Flink怎么设置不开启checkpoint

Flink怎么设置不开启checkpoint

问答 2024-04-02 来自:开发者社区

Flink CDC里请问flink1.7如何设置持久化checkpoint到阿里云oss啊?

Flink CDC里请问flink1.7如何设置持久化checkpoint到阿里云oss啊?文档中的是savepoint checkpoint也是一致的是吗?

问答 2024-03-05 来自:开发者社区

Flink CDC中operator如何设置自动清理旧的checkpoint数据呢?

Flink CDC中operator如何设置自动清理旧的checkpoint数据呢?因为我的sql融合了很多表状态数据很大,但是看checkpoints有很多旧的,如何配置flink operator自动清理呢?streampark好用吗?感觉国内主导的很难稳定

问答 2023-12-11 来自:开发者社区

Flink CDC 我提交任务到k8s上运行。但里面设置的checkpoint的时间间隔一直不生效?

Flink CDC 我提交任务到k8s上运行。但里面设置的checkpoint的时间间隔一直不生效?(我在代码中设置的是720000ms,720s但是web界面显示的是默认值30s,如下图),请问如何使这个值生效呀?我的任务提交语句是./bin/flink run-application --target kubernetes-application --parallelism 3 -Dkube....

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

Flink CDC这个归档速度跟设置的checkpoint周期设置有关系吗?

Flink CDC这个归档速度跟设置的checkpoint周期设置有关系吗?我把周期设置大一些,能缓解这个问题吗?

问答 2023-11-15 来自:开发者社区

Flink CDC这个可以设置发生异常job退出时自动保存一次checkpoint吗?

Flink CDC间隔时间设置这么长,如果中间发生异常JOB停止了,是不是chekpoint可能是1个小时前的chekpoint,这个可以设置发生异常job退出时自动保存一次checkpoint吗?

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

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

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

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

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没?

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没有了,然后我重启了,有没有办法从上一次checkpoint开始操作呢?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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