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

我使用Flink cdc整库同步mysql,之前设置多表同步101个表, 这种state是否合理?

我使用Flink cdc整库同步mysql,之前设置多表同步101个表, 今天新增了1个表,然后重新部署,我还是沿用之前的状态(“有状态启动”),发现在holo这边会新建这个新增的表, 但是数据没写入, 这种state是否合理?还是说每次新增表都要使用“无状态启动”,才能写数据

文章 2024-01-04 来自:开发者社区

Flink CDC 3.0中,如果你想在同步MySQL数据时排除某列

在Flink CDC 3.0中,如果你想在同步MySQL数据时排除某列,你可以在创建Source表时使用EXCLUDE_ALL选项。以下是一个示例: CREATE TABLE source_table ( id INT, name STRING, age INT ) WITH ( 'connector' &...

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

Maria-RDS 可以同步到云数据仓库ADB 吗?

Maria-RDS 可以同步到云数据仓库ADB 吗?

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

flink cdc 3.0 同步mysql 数据,怎么配置排除某列?

flink cdc 3.0 同步mysql 数据,怎么配置排除某列?

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

flink cdc作业同步mysql一个数据库下面的多个表,运行一段时间后,使用中还是有这个问题?

flink cdc作业同步mysql一个数据库下面的多个表,运行一段时间后,停止作业新增一张表,从savepoint启动,所有表都doump了,看issue找到相同的问题,https://github.com/ververica/flink-cdc-connectors/pull/2096,flinkcdc 3.0.0按道理应该解决了,但是使用中还是有这个问题?

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

Flink CDC从mysql同步数据到doris,这是咋回事?

Flink CDC从mysql同步数据到doris,同步的历史数据中时间字段类型都是null,但是增量部分的时间类型的字段都会正常显示,这是咋回事?

文章 2023-12-30 来自:开发者社区

使用Flink CDC从SQL Server同步数据到MySQL

为了使用Flink CDC从SQL Server同步数据到MySQL,你需要按照以下步骤进行: 环境准备:首先,确保你有一台安装了Java环境的centos系统的主机或虚拟机。 下载Flink和相关jar包:访问Flink官网下载Flink安装包。然后,下载以下jar包: flink-sql-con...

文章 2023-12-29 来自:开发者社区

在kafka connect 同步 mysql 主从数据库

在kafka connect 同步 mysql 主从数据库下载以下文件,解压,放置到kafka的libs目录kafka-connect-jdbc-4.1.1从这里选择适合的mysql connectormysql-connector-java-8.0.16.jar将里面的jar文件提取出来,也放到kafka的libs目录在config目录下创建 connect-mysql-source.prop....

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

使用CTAS把mysql表同步数据到hologres,Flink有什么参数可以使字段都小写?

使用CTAS 把mysql 表同步数据 到hologres ,Flink有什么参数可以使hologres 的字段都小写吗?因为mysql 有大写也有小写,比较混乱,我想holo做个统一

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

数据传输DTS在mysql之间同步时,可以屏蔽索引的DDL吗?

数据传输DTS在mysql之间同步时,可以屏蔽索引的DDL吗?

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

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像