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

Flink CDC里可以一次捕获一个事物提交的数据吗?

Flink CDC里可以一次捕获一个事物提交的数据吗,这样在入库的时候可以批量入库。

问答 2024-04-16 来自:开发者社区

Flink CDC为啥已经指定了读取的表但是启动时的这个步骤捕获了库里面所有的表结构?

Flink CDC为啥已经指定了读取的表但是启动时的这个步骤捕获了库里面所有的表结构,不是指定schema的也捕获了,用了十几分钟。是怎么回事呢?

问答 2024-04-08 来自:开发者社区

Flink CDC里利用flink捕获sqlserver日志,如何解决日志文件增长过快?

Flink CDC里利用flink捕获sqlserver日志,sqlserver开启cdc后会导致ldf日志文件迅速增长,各位大佬是如何解决日志文件增长过快的?

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

Flink CDC产品常见问题之flink Oraclecdc 捕获19C数据时报错错如何解决

问题一:Flink CDC里有人了解mysql binlog生成机制吗 ? Flink CDC里有人了解mysql binlog生成机制吗 ? flink cdc为什么有时候能读到binlog 有时候不能啊? 参考回答: MySQL Binlog(二进制日志)是MySQL数据库用于记录所有更改数据的逻辑日志,包括数据的增删改操作。MySQL通过启用二进...

Flink CDC产品常见问题之flink Oraclecdc 捕获19C数据时报错错如何解决
文章 2024-03-09 来自:开发者社区

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

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

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

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

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

问答 2024-02-21 来自:开发者社区

Flink CDC利用Debezium技术捕获并处理数据库的所有变更,包括DDL事件。是不是这样?

Flink CDC利用Debezium技术捕获并处理数据库的所有变更,包括DDL事件。是否可以理解为Flink CDC可以作为一个全能工具,取代诸如阿里云DTS、Canal、Maxwell等数据同步工具,实现全量+增量的数据同步任务?

问答 2024-02-20 来自:开发者社区

通过Flink CDC 同步db2表数据,为什么db2数据类型是xml时候,捕获的日志中不包含呢?

通过Flink CDC 同步db2表数据,为什么db2数据类型是xml时候,捕获的日志中不会包含该字段,比如db2:create table SUPPLIERS( SID VARCHAR(10) not null constraint PK_PRODUCTSUPPLIER primary key, ADDR XML); 日志:record: {"...

文章 2024-02-20 来自:开发者社区

Flink CDC(Change Data Capture)是一种用于捕获数据库变更的技术

如果Flink CDC的Oraclecdc JdbcIncrementalSource捕获不到数据也不报错,可能是以下原因: 检查数据库连接是否正常,可以尝试使用其他工具连接数据库,确认连接是否成功。 检查JdbcIncrementalSource的配置是否正确,特别是表名和字段名是否正确。 检查Flink任务的并行度是否设置...

问答 2024-02-14 来自:开发者社区

flink oracle cdc 支持捕获 DDL吗?

flink oracle cdc 支持捕获 DDL吗? 试了一下 好像 没有includeSchemaChanges参数 可以开启DDL的捕获。

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

产品推荐

实时计算 Flink

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

+关注