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

Flink CDC 采集mysql,全量采集不报错,就是没数据,是啥原因?

Flink CDC 采集mysql,全量采集不报错,就是没数据,是啥原因?

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

flink CDC可以直接将mysql中的数据直接写入到hive中吗? 有没有相关demo啊 ?

flink CDC可以直接将mysql中的数据直接写入到hive中吗? 有没有相关demo啊 ?

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

Flink CDC mysql 时间数据是UTC timestamp(3),这种大家是怎么处理的?

Flink CDC mysql 时间数据是UTC timestamp(3),想要同步到es的时候格式也是timestamp(3) ,但是数据库里面有时间是 2021-02-20 17:44:53.110 比如这种同步到es的时候就会报错 格式少了一位,这种大家是怎么处理的?

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

Flink CDC 我现在使用CDC同步mysql数据,中文的显示乱码,这是咋回事呀?

Flink CDC 我现在使用CDC同步mysql数据,中文的显示乱码,这是咋回事呀?我用的是官方的样例

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

Flink CDC mysql 2.4.1抽取数据遇到这个问题 ?

Flink CDC mysql 2.4.1抽取数据遇到这个问题 ? Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=169346457400....

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

Flink CDC中按github上的例子 mysql数据变动后程序的日志没变化?

Flink CDC中按github上的例子 mysql数据变动后程序的日志没变化?

问答 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.....

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

Flink CDC读取mysql的数据 这个读取的数据有update吗?

Flink CDC读取mysql的数据 操作类型以后就没有update了,这个读取的数据有update?我们这业务比较恶心 有物理删除的操作

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

Flink CDC读取mysql 2.3版本 如果是更新数据 是先删除 后插入了嘛?

Flink CDC读取mysql 2.3版本 如果是更新数据 是先删除 后插入了嘛? 我记得以前是update的呀?我用的API

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

有没有办法控制flink在cdc读取完mysql存量数据?

有没有办法控制flink在cdc读取完mysql存量数据,开始读取增量数据的时候才开始读取其他数据源的数据?现在cdc和kafka source同时执行,就会出现kafka数据读进来开始处理的时候,cdc还没有从mysql中读取到配置信息。

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

产品推荐

阿里云实时计算Flink

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

+关注