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

使用flink cdc监听一个mysql表的binlog,debezuim反序列化日志 报错,为什么

使用flink cdc监听一个mysql表的binlog,但是现在再该库下新增了一个表,但是由于字段类型不对,然后修改了字段,然后就导致 debezuim反序列化日志 报错,为什么?

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

为啥Flink CDC官网只提截图的元数据?我想拿到binlog的操作类型,比如添加,修改,删除

为啥Flink CDC官网只提截图的元数据?我想拿到binlog的操作类型,比如添加,修改,删除

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

Flink CDC有办法指定从哪个binlog的posid开始重跑吗?

flinkcdc任务重建,也就是同一个任务因为后续数据增加变化代码更改,cancel之后,代码更新,重跑该任务,想从cancel之后的mysql-binlog开始重跑,不想触发之前的全量数据,有什么办法吗?有办法指定从哪个binlog的posid开始重跑吗?

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

对于Flink CDC,同一主键,binlog时间戳也是一致的,应该怎么排序merge呢?

对于Flink CDC,同一主键,binlog时间戳也是一致的,应该怎么排序merge呢?

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

对于Flink CDC,想把cdc MySQL binlog 的数据。怎么设计好呢?

对于Flink CDC,想把cdc MySQL binlog 的数据。推进Kafka 功其他业务消费。 同时又要按每小时做预聚合统计。 然后写到starrocks 这个怎么设计好呢?

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

flink cdc 2.1.0消费binlog作业,发现作业停止后为啥数据库连接一直保持着?

flink cdc 2.1.0消费mysql binlog作业,发现作业停止后数据库连接一直保持着,会是什么原因?

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

flink cdc 读MySQL 只能使用binlog_format=ROW这种方式吗?

flink cdc 读MySQL 只能使用binlog_format=ROW这种方式吗?

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

对于Flink CDC,如果binlog保留时间只有1天,是不是就拿不到全量数据了?

mysql 全量阶段(snapshot)也是依赖binlog获取数据吗,如果binlog保留时间只有1天,是不是就拿不到全量数据了?

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

flink-cdc 采集mysql binlog,可以指定从特定时间戳开始么?

flink-cdc 采集mysql binlog,可以指定从特定时间戳开始么?

文章 2022-12-28 来自:开发者社区

Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server

问题描述Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.问题...

Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server

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