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

Flink CDC中upsert-kafka作为数据源,如果加了字段,这个有什么好办法嘛?

Flink CDC中upsert-kafka作为数据源,如果加了字段,就不能从savepoint启动,不从savepoint 就只能从头消费,这样需要很长时间才能追上。这个有什么好办法嘛,目前我们都是再启动一个任务,追上之后再做切换?

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

Flink CDC有什么办法能实现新加的表从最新binlog开始消费吗?

Flink CDC有什么办法能实现新加的表从最新binlog开始消费吗?

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

Flink CDC目前pipeline 还是没有办法从savepoint恢复?

Flink CDC目前pipeline 还是没有办法从savepoint恢复?

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

Flink CDC有没有办法返回这种数据类型的数据?

Flink CDC有没有办法返回这种数据类型的数据?

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

Flink CDC中oracle cdc 导致数据库日志空间暴增 这个有办法解决嘛?

Flink CDC中oracle cdc 导致数据库日志空间暴增 这个有办法解决嘛?

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

flink cdc全量从oracle写入到kakka,报错,有办法解决么?

flink cdc全量从oracle写入到kakka,报错,有办法解决么?好像可性了,同步了13个多小时没有挂掉

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

Flink读取mysql cdc有办法过滤掉 update_before类型的数据嘛?

Flink读取mysql cdc有办法过滤掉 update_before类型的数据嘛?

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

Flink CDC中sqlserver--->sqlserver。反压严重,大家有啥好办法不?

Flink CDC中sqlserver--->sqlserver。反压严重,大家有啥好办法不?

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

Flink CDC在使用oracle cdc监控数据库,参数设置,还有其他办法么?

Flink CDC在使用oracle cdc监控数据库,系统打印LogMiner is now using the maximum batch size 100000....,继而无法监控数据变更,除了调大log.mining.batch. size.max参数设置,还有其他办法么? 这个过程中缺失的数据有啥办法能重新捕获到嘛?

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

Flink CDC有没有办法可以做到cdc表更新以后就去数据库查询最新的jdbc表呢?

Flink CDC中flinksql进行一个3张表的全量加增量实时联表同步,现在我如果3张表都用cdc连接器,flink程序的内存就会涨的很快,如果设置状态过期时间,就会导致数据丢失,因为不同表的时间跨度可能会比较长 现在,我把这三张表更新最迟的一个表使用cdc连接器,其余两个使用jdbc连接器,但是flink会缓存jdbc的表,所以联表执行的不是数据库的最新数据,有没有办法可以做到cdc表更新....

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

产品推荐

实时计算 Flink

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

+关注