问答 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 mysql可以实时集成到hive吗?

Flink CDC mysql可以实时集成到hive吗?

高性能

基于 Flink CDC 打造企业级实时数据同步方案

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

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

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

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

Flink CDC 读取mysql,TM中一致打印?

Flink CDC 读取mysql,TM中一致打印 Stopped reading binlog after 0 events, no new offset was recorded。这是什么原因?

问答 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-07 来自:开发者社区

Flink CDC mysql可以实时集成到hive吗?

问题1:Flink CDC mysql可以实时集成到hive吗?问题2:mysql 实时同步 kudu吗?目前看实时同步hive确实没有什么方法,下游只能接一个可以执行update的数据库。

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

flink cdc如何执行一个批作业,将当前的mysql一个表导入到其他地方?

flink cdc如何执行一个批作业,将当前的mysql一个表导入到其他地方,执行完全量阶段后,自动停止呀?我测试过initial_only 并不能停止任务,jdbc的connector读取和cdc的读取还是有些差异吧。cdc我认为对线上库更友好一些?

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

Flink CDC这个问题嘛我这个使用look up mysql,但是这个为啥显示finished了

Flink CDC这个问题嘛我这个使用look up mysql,但是这个为啥显示finished了呀 是lookup后都是结束状态麻?

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

请教我Flink CDC这个使用look up mysql,但是这个为啥显示finished了呀 ?

请教我Flink CDC这个使用look up mysql,但是这个为啥显示finished了呀 是lookup后都是结束状态麻?

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

产品推荐

实时计算 Flink

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

+关注