文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之flink-cdc任务抓取全量的mysql数据不生效如何解决

问题一:Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,不生效怎么办? Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,checkpoint目前是持久化到oss上,我希望每次重启任务的时候不要从头开始抓取所有的消息。我的想法是在任务里面直接获取oss上最新进度的checkpoint目录,然后通过SavepointResto...

Flink CDC产品常见问题之flink-cdc任务抓取全量的mysql数据不生效如何解决
问答 2024-02-01 来自:开发者社区

Flink CDC里在用flink-cdc连接postgresql时,插槽不能重复吗?

Flink CDC里在用flink-cdc连接postgresql时,插槽不能重复吗?逻辑插槽可以复用不?

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

Flink CDC在使用flink-cdc 从mysql 进行实时同步到目标库的方案中,这种怎么办?

Flink CDC中,想了解Flink 3.0是否提供了针对MySQL连接数限制的技术优化措施?

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

Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,不生效怎么办?

Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,checkpoint目前是持久化到oss上,我希望每次重启任务的时候不要从头开始抓取所有的消息。我的想法是在任务里面直接获取oss上最新进度的checkpoint目录,然后通过SavepointRestoreSettings去恢复任务进度,但是不生效。请问是什么情况,或者有没有别的更好解决方案?

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

Flink CDC里stream park有计划接入flink-cdc 3.0来管理任务吗?

Flink CDC里stream park有计划接入flink-cdc 3.0来管理任务吗?

文章 2023-11-01 来自:开发者社区

flink1.18发布与flink-cdc有重大相关调整吗?

Apache Flink CDC 在 Flink 1.18 发布之后进行了许多优化和改进,主要包括以下几个方面: 加入了新的功能,如分区表的创建、聚合函数的支持以及 SQL 表达式的扩展等;新增了一些功能,如从多个源节点同步增量变化;对现有的CDC功能进行了增强和完善,比如性能优化和错误修复等。 以...

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

flink-cdc 2.4.1 应该搭配什么版本的Flink,现在报guava30找不到类?

flink-cdc 2.4.1 应该搭配什么版本的Flink,现在报guava30找不到类?

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

flink1.18发布与flink-cdc有重大相关调整吗?

flink1.18发布与flink-cdc有重大相关调整吗?

问答 2023-10-18 来自:开发者社区

flink-cdc可以使用 flink 的 kafka avro格式对接吗?

flink-cdc写入 Upsert Kafka avro格式 可以使用 flink 的 kafka avro格式对接吗?

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

flink-cdc 读取mysql double类型 进入flink变成科学计数法了这怎么破?

flink-cdc 读取 mysql double类型 进入flink 变成科学计数法了 这怎么破。使用table API ?

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

产品推荐

实时计算 Flink

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

+关注