问答 2022-12-20 来自:开发者社区

flink cdc消费binlog报错,解析日期格式失败大家有遇到过吗?针对这种情况怎么设置默认值?

flink cdc消费binlog报错,解析日期格式失败大家有遇到过吗?针对这种情况怎么设置默认值? java.time.format.DateTimeParseException: Text '0000-00-00 00:00:00' could not be parsed

问答 2022-11-20 来自:开发者社区

在flink sql中用mysql cdc 同步数据, 每一张表同步都会创建一个binlog dum

在flink sql中用mysql cdc 同步数据, 每一张表同步都会创建一个binlog dump. 这样对上游业务可能会造成影响, 有相关配置可以实现一个实例对应一个dump线程吗?我在cdc官方文档 没有找到相关的配置

问答 2022-11-17 来自:开发者社区

为什么2.3的flink cdc 抽的binlog的时间是0?

为什么2.3的flink cdc 抽的binlog的时间是0?

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

flink cdc内置了kafka 监听binlog文件的时候 是把所有监听的数据写入kafka的

还是只是记录偏移量 数据还是从biglog取的

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

请问下Flink CDC datastream 采集mysql binlog数据,如何每次重启的时候

请问下Flink CDC datastream 采集mysql binlog数据,如何每次重启的时候采集全量数据,而不是从上一次binlog的位置解析读取?

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

使用flink cdc官方案例,读取mysql binlog日志 到 flink,为何没有输出?

使用flink cdc官方案例,读取mysql binlog日志 到 flink,为何没有输出? 背景:flink1.12, cdc 2.2

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

我开启 flink cdc作业后 为什么 数据库 上那么多 binlog 解析器

我开启 flink cdc作业后 为什么 数据库 上那么多 binlog 解析器

问答 2022-09-27 来自:开发者社区

flink cdc有没有异步缓存的实现,解决binlog消失太快的问题

flink cdc有没有异步缓存的实现,解决binlog消失太快的问题

问答 2022-09-23 来自:开发者社区

flink cdc每次必须消费整库的binlog么?

flink cdc每次必须消费整库的binlog么?

问答 2022-09-08 来自:开发者社区

Flink CDC在获取全量数据阶段的时候是基于查询的,还是基于binlog日志的呢?

如果是数据采集的这个阶段的话,是不是依靠什么无锁算法啥的处理一致性的,但是我就是觉得Flink CDC在获取全量数据阶段的时候是基于查询的,还是基于binlog日志的呢?

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

产品推荐

阿里云实时计算Flink

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

+关注
登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问