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

Flink CDC中SqlServer 和postgre需要开启啥日志?

Flink CDC中开启flink cdcMySQL需要开启binlog日志,Oracle需要归档日志,SqlServer 和postgre需要开启啥日志?

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

Flink CDC中sqlserver 监听 偶尔会报这个错误怎么解决?

"Flink CDC中sqlserver 监听 偶尔会报这个错误:Caused by: org.apache.kafka.connect.errors.DataException: file is not a valid field name at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254) ~[?:?] a....

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

Flink CDC中sqlserver同步过程中,先全量然后增量,会出现直接暂停的现象,什么原因?

"Flink CDC中sqlserver同步过程中,先全量然后增量,会出现直接暂停的现象,我看代码似乎是触发了增量同步,然而实际上表并没有任何数据改动,如果数据库其他cdc表没有变动不会出现这个问题,实际上全量没有完全,在方法里面出不来了,什么原因?版本2.4.1。"

问答 2023-07-26 来自:开发者社区

Flink CDC中sqlserver cdc 我只指定一个数据库它却把其他数据库下的同名表为什么?

Flink CDC中sqlserver cdc ,我只指定了一个数据库··它却把其他数据库下的同名表都给监听了···是我哪里写法不对吗?其实有很多别的数据库都有tablelist里的表,现状是所有库里的同名表都被监听了,我不想flink监听我没指定的数据库的表。我代码里只指定了A数据库下的 dbo.xx表~实际上运行下来flink监听了A,B,C所有数据库下面的dbo.xx表。我的 sink .....

问答 2023-07-26 来自:开发者社区

Flink CDC中sqlserver 指定databaseList 不分割,这个怎么处理?

Flink CDC中sqlserver 指定databaseList 不分割,这个怎么处理?

问答 2023-07-26 来自:开发者社区

Flink CDC中cdc-2.4采集sqlserver时同一个IP实例下两个不同的库有相同名的表?

Flink CDC中cdc-2.4,采集sqlserver的时候,同一个IP实例下两个不同的库有相同表名的表,导致采集错了库 这个问题怎么解决?

实时计算 Flink

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

+关注