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

Flink CDC mysql同步到doris,从哪里出来的?想问下有什么思路么?

Flink CDC mysql同步到doris,报数据类型转换错误 Caused by: java.lang.NumberFormatException: For input string: "UTF8MB4'0",分析不出来这个 "UTF8MB4'0" 从哪里出来的?想问下有什么思路么?CREATE TABLE mysql表 ( id int(11) unsigned NOT NULL A...

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

Flink CDC有没有大佬做过mysql表的数据吧一对多的父子表同步到es中的需求呢,帮解答一下?

Flink CDC有没有大佬做过mysql表的数据吧一对多的父子表同步到es中的需求呢,我想知道flink sql是否有这样的能力,然后我就写sql去试,就发现这一条sql可以跑通,但是是固定数据INSERT INTO es_album_info SELECT a.id,a.name,author_id authorId,(select ROW(id,name) from author whe.....

高性能

Flink CDC 实现企业级实时数据同步

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2023-09-06 来自:开发者社区

Flink CDC只支持有主键的同步吗?

Flink CDC只支持有主键的同步吗?我用dataphin,没主键的元表不让我提交

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

Flink CDC我是在程序里面把整库同步进行了集成,用savepoint重启任务就是报错?

问题1:Flink CDC我是在程序里面把整库同步进行了集成,程序里启停任务,现在问题是同步数据时候,以前是5张表,一个任务,现在改为7张表一个任务后,用savepoint重启任务就是报错?需要设置allowNonRestoredState参数问题2:命令方式,我也看到有,就是程序里配置,一直找不到

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

请问下我使用flink cdc 同步联合主键的mysql表同步不了,是不支持联合主键表吗?

请问下我使用flink cdc 同步联合主键的mysql表同步不了,是不支持联合主键表吗?

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

Flink CDC同步oracle表 一个表一个session的问题怎么优化呢?

Flink CDC同步oracle表 一个表一个session的问题怎么优化呢?

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

Flink CDC删除同步到es里数据的原理是什么呢?

Flink CDC删除同步到es里数据的原理是什么呢,删除product表里的记录,程序是如何去es里删除的呢? 我们以前用canal做是配置了一个key,通过这个key去删除。数据已经存储到es里了,要删除es里的数据就要指定条件删除,从表product删除一条数据后会发生什么呢?有没有这方面的资料看看?

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

Flink CDC这种是chunk 后, 然后同步数据完成了再来关闭的意思吗?

Flink CDC这种是chunk 后, 然后同步数据完成了再来关闭的意思吗?

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

Flink CDC 并行度的设置和 splitSize 这两个大了直接就不同步了, 这是什么情况呢?

Flink CDC 并行度的设置和 splitSize 这两个大了直接就不同步了, 这是什么情况呢? 你遇到过没

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

Flink CDC能同步Mysql的视图吗?

Flink CDC能同步Mysql的视图吗?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注