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

Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务怎么办?

Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务,这个时候没法预知去手动savepoint,该如何处理呢?

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

Flink CDC里每次重新启动任务它都会新建的话如何保证断点续传呢?

Flink CDC里我的flink任务每次启动都会在我给的checkpoint目录下面用随机字符串建立子目录,这样我每次重新启动任务它都会新建的话如何保证断点续传呢?我是通过FlinkDeployment部署到云上,启动的时候我尝试这样加过参数,但是貌似起不了作用,可能因为我这个目录是checkpoint自动生成的,不是我手动savepoint的?

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

Flink CDC中SQLserver 支持断点续传吗?

Flink CDC中SQLserver 支持断点续传吗?指定checkpoint来启动

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

flink mysql cdc 2.3.0 版本, 想要断点续传 怎么弄?

flink mysql cdc 2.3.0 版本, 想要断点续传 在SourceRecord sourceRecord获取的 partitionMap = sourceRecord.sourceOffset();offsetMap = sourceRecord.sourcePartition(); file 都是空的,正常应该是。binlog-202xxx.log文件名称?

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

Flink CDC断点续传 的例子哪儿能找到,网上找了一些都不好用?

Flink CDC断点续传 的例子哪儿能找到,网上找了一些都不好用?我想在程序中使用flinkcdc savepoint存在本地

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

Flink CDC本地local模式。断点续传可以操作吗?

Flink CDC本地local模式。断点续传可以操作吗?

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

Flink CDC支持断点续传吗,有没有示例?

Flink CDC支持断点续传吗,有没有示例?

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

Flink CDC有没有大佬试过flinkcdc可以断点续传这个东西?就是我现在想着假如有时候?

Flink CDC有没有大佬试过flinkcdc可以断点续传这个东西?就是我现在想着假如有时候flink因为某些原因,挂了,然后我弄一个自动重启的程序

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

Flink CDC最新的版本支持全量阶段断点续传吗,是到分片级吗?

Flink CDC最新的版本支持全量阶段断点续传吗,是到分片级吗?

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

Flink CDC中断点续传的功能怎么开启,每次我重新启动代码还是从零开始读?

Flink CDC中断点续传的功能怎么开启,每次我重新启动代码还是从零开始读?我是sqlserver 2016版本的。

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

产品推荐

实时计算 Flink

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

+关注