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

在Flink CDC中mysql cdc的这个参数的时间戳是填什么吗?

在Flink CDC中mysql cdc的这个参数的时间戳是填什么吗,随便填一个时间就能从那个时间开始的binlog读取吗,scan.startup.mode?

文章 2024-05-18 来自:开发者社区

实时计算 Flink版产品使用合集之在抓取 MySQL binlog 数据时,datetime 字段会被自动转换为时间戳形式如何解决

问题一:Flink这个问题怎么解决? Flink这个问题怎么解决?代码实现mongo数据整库写hudi,采用RocksDBStateBackend状态后端,checkpoint产生的文件名太长报错 参考回答...

实时计算 Flink版产品使用合集之在抓取 MySQL binlog 数据时,datetime 字段会被自动转换为时间戳形式如何解决

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
326 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
962 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
520 人已学 |
免费
开发者课程背景图
问答 2024-02-06 来自:开发者社区

Flink CDC里MySQL CDC Pipeline 整库同步时 从指定的时间戳开始读取 吗?

Flink CDC里MySQL CDC Pipeline 整库同步时 从指定的时间戳开始读取 binlog 事件,然后 在指定的时间戳 结束任务 吗?目前看文档只能配置开始吗?能否指定结束时间呢 或者有其他方式实现么?

问答 2023-11-15 来自:开发者社区

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

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

flink-core抓mysql-binlog,字段datetime会自动转换成时间戳,怎么解决?

flink-core抓mysql-binlog,字段类型datetime会自动转换成时间戳,大佬们有遇到过的吗?怎么解决?

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

flink-mysqlcdc读取mysql,为什么cdc读取之后变成了时间戳?

flink-mysqlcdc读取mysql,在mysql中格式是yyyy-MM-dd HH:mm:ss ,为什么cdc读取之后变成了时间戳?拿了一条具体的时间对比,还相差了8个小时1646093020000 = 2022-03-01 08:03:40实际mysql中的时间是2022-03-01 00:03:40

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

Flink CDC中mysql cdc启动模式的timestamp,这个时间戳是相对于那个事件?

Flink CDC中mysql cdc启动模式的timestamp,这个时间戳是相对于那个事件?是记录发生变化的时间吗?

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

Flink CDC的读取mysql支持时间戳启动么?

Flink CDC的读取mysql支持时间戳启动么?如果支持时间戳启动的话 就算我以后升级集群 直接改一下启动时间不就可以了 就不用手动补数据了,但是我目前版本用的是不支持时间戳启动 不知道是dinky不支持还是flink版本不支持还是cdc版本不支持,是cdc版本低所以不支持是吧?

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

Flink CDC中mysql-cdc从时间戳启动,发现本地IDEA测试不行,什么原因?

Flink CDC中mysql-cdc从时间戳启动,发现本地IDEA测试不行,但是集群测试,是有数据出来,但是数据有问题呢。昨天插入了两条数据,时间戳设置为之前的,只有昨天插入的两条数据进来。今天测试了下,只有昨天插入的最后一条数据出来,是啥情况?我看binlog的失效时间是1个月的。

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

Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?

Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?使用的是dataStream的方式,flink的版本:1.15.3,mysql的版本:8.0.18, connector的版本:flink-connector-mysql-cdc 2.4.0。测试代码:

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

产品推荐

阿里云实时计算Flink

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

+关注