文章 2023-10-25 来自:开发者社区

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除: 使用DELETE语句:在Flink SQL中,可以直接使用DELETE语句从结果表中删除数据。例如: DELETE FROM result_table WHERE id IN (SELECT id FROM source_tabl...

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

Flink CDC怎样设置StartupOptions,来保证数据的连续行呢?

Flink CDC假设我的cdc任务有问题自动终止了,或者被kill掉了, 一段时间后再重启,怎样设置StartupOptions,来保证数据的连续行呢?

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

Flink CDC问下PG 可以支持从slave同步数据了吗 ?

Flink CDC问下PG 可以支持从slave同步数据了吗 ?

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

Flink CDC1.13.6 cdc 2.3 同步MySQL的数据报的这个错误是什么问题?

Flink CDC1.13.6 cdc 2.3 同步MySQL的数据报的这个错误是什么问题?

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

Flink CDC增量快照发生在哪个阶段?是同步历史数据的时候吗?还是啥时候?

Flink CDC增量快照发生在哪个阶段?是同步历史数据的时候吗?还是啥时候?我记得只有读取历史数据的时候才会做快照

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

Flink CDC mysql连接器配置这个选项,为啥不同步历史数据呢?

Flink CDC mysql连接器配置这个选项,为啥不同步历史数据呢?

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

请教下Flink CDC, oracle-cdc读取数据提示用户不存在是哪里写错了么?

请教下Flink CDC, oracle-cdc读取数据提示用户不存在是哪里写错了么?

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

请教一下我是用的是flink 1.17 , cdc是2.4.0 。没有打印数据?

请教一下我是用的是flink 1.17 , cdc是2.4.0 。就是简单执行 sql-client ,mysql 作为source table ,然后select * from ,但是没有打印数据,webui 上的任务的bytes received 也是0。 查看taskmanager 日志上是动态打印新增的binlog 和 pos信息的。

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

请教一个Flink CDC问题。增量同步一段时间就无法在获取到数据了?

请教一个Flink CDC问题。使用Flink 1.14 CDC,获取TIDB得数据。增量同步一段时间就无法在获取到数据了。

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

Flink CDC有同学碰到过删除已经同步的表之后再创建这张表时,历史数据不同步的问题么?

Flink CDC有同学碰到过删除已经同步的表之后再创建这张表时,历史数据不同步的问题么?

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

产品推荐

实时计算 Flink

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

+关注