文章 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-03-09 来自:开发者社区

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决

问题一:Flink CDC里有没有遇到这些情况,啊? Flink CDC里有没有遇到这些情况,啊? 如果任务不重启, 不管是新增删除编辑都是没有问题的, 只要有一端的flink任务重启了, 就会出现以下问题: mysql同步到kafka(采集数据), 再由kafka同步kafka(搬运数据), 再由kafka同步到mysql(数据落库), 当停止采集或者落库任务后, 再次启动采...

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决

问题一:Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后有点数据开始从0聚合? Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后,有点数据开始从0开始聚合了啊?有的数据是正常的,有的数据的清0了,我这边没有设置TTL,状态也会过期吗? 参考回答: 在Flink CDC中进行Lookup Joi...

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决
问答 2024-03-08 来自:开发者社区

Flink CDC 获取hologres数据报错

我在本地尝试通过Flink CDC监控hologres的表数据,运行程序报错,如下图代码在这里:这个问题要怎么解决呢?

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

如果用Flink cdc 直接接业务数据,我们应该怎么去避免我们下游的计算任务和接入不出问题?

如果用Flink cdc 直接接业务数据,如果突然业务这边要回刷一整年的订单某个一段。这种我们应该怎么去避免我们下游的计算任务和接入不出问题,这个数据量和资源有比例吗?

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

Flink CDC在处理数据时,会将字段名转换为小写

Flink有人遇到这个问题不?Q FlinkCDC全量没问题,增量报错fileisnotavalidfieldname源端oradle和目标mysql库都没有fle字段:Causedby:com.ververicadc.connectrs.shaded.rgapache.kafkaonnect.rrs.DataExceptin:fleisnotavali...

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

Flink CDC异构数据源之间的数据映射关系吗?

Flink CDC异构数据源之间的数据映射关系吗?比如:Oracle 的NUMBER 同步到 MySQL 中 应该用什么类型?

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

有没有碰到Flink CDC作业正常运行但是部分数据可以更新过来,有些数据无法更新过来?

有没有小伙伴碰到Flink CDC作业正常运行但是部分数据可以更新过来,有些数据无法更新过来?

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

Flink CDC可以通过正则.*捕获新增表的数据了, 但是可以过滤掉DML操作吗?

Flink CDC用来master分支后, 可以通过正则.*捕获新增表的数据了, 但是可以过滤掉DML操作吗?建表语句这些我不想要

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

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

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

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

产品推荐

实时计算 Flink

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

+关注