Flink CDC产品常见问题之binlog 过期如何解决

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: Flink CDC(Change Data Capture)是一个基于Apache Flink的实时数据变更捕获库,用于实现数据库的实时同步和变更流的处理;在本汇总中,我们组织了关于Flink CDC产品在实践中用户经常提出的问题及其解答,目的是辅助用户更好地理解和应用这一技术,优化实时数据处理流程。

问题一:通过Flink CDC 同步db2表数据,为什么db2数据类型是xml时候,捕获的日志中不包含呢?

通过Flink CDC 同步db2表数据,为什么db2数据类型是xml时候,捕获的日志中不会包含该字段,比如db2:create table SUPPLIERS

(

SID VARCHAR(10) not null

constraint PK_PRODUCTSUPPLIER

primary key,

ADDR XML

); 日志:record: {"before":null,"after":{"SID":"100"},"source":{"version":"1.9.7.Final","connector":"db2","name":"db2_cdc_source","ts_ms":1708200234371,"snapshot":"true","db":"doriscdc","sequence":null,"schema":"DB2INST1","table":"SUPPLIERS","change_lsn":null,"commit_lsn":null},"op":"r","ts_ms":1708229034630,"transaction":null}



参考答案:

xml 和Boolean好像都有这个问题。



关于本问题的更多回答可点击进行查看:

https://developer.aliyun.com/ask/598579?spm=a2c6h.12873639.article-detail.82.50e24378TRW91E



问题二:Flink CDC里flink1.18.1执行sql报错那里有问题?

flink cdc 里flink1.18.1执行sql报错,Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.base.source.reader.RecordEmitter,是哪里有问题?另外有引入也有flink-client,可以帮忙看下吗?



参考答案:

那只能怀疑是包冲突了,建议排查看看吧。



关于本问题的更多回答可点击进行查看:

https://developer.aliyun.com/ask/598577?spm=a2c6h.12873639.article-detail.83.50e24378TRW91E



问题三:Flink CDC里这俩是什么关系?

Flink CDC里flink-connector-oracle-cdc-3.0-SNAPSHOT和flink-sql-connector-oracle-cdc-3.0-SNAPSHOT是啥关系呀?



参考答案:

包含关系 。



关于本问题的更多回答可点击进行查看:

https://developer.aliyun.com/ask/597944?spm=a2c6h.12873639.article-detail.84.50e24378TRW91E



问题四:Flink CDC里为什么这里又要重新定义一遍options呀?

https://github.com/ververica/flink-cdc-connectors/blob/master/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/com/ververica/cdc/connectors/doris/sink/DorisDataSinkOptions.java

Flink CDC里为什么这里又要重新定义一遍options呀?doris官方的flink connector不是有options吗?唯一不同的是ConfigOption包名,一个来自ververica,另一个来自flink



参考答案:

在 Apache Flink CDC 中,你可能会遇到需要重新定义连接器选项的情况,这是因为不同的Flink connector可能来自不同的开发团队或项目,它们在设计和实现时可能使用了不同的配置选项接口或包。例如,Ververica(原DataArtisans,被阿里云收购后继续贡献Flink)可能为Flink CDC提供了一套特定的连接器,并使用了来自com.ververica.cdc.connectors.mydatabase.MyDatabaseOptions之类的包中的ConfigOption

而Doris官方或者社区提供的Flink connector可能有不同的实现方式,因此其配置选项可能位于org.apache.flink.connector.doris.options.DorisOptions等这样的包中。

尽管两者都是为了连接到数据源并配置相关参数,但由于这些connector是独立开发的组件,其内部使用的配置API和结构并不相同。这意味着当你要切换或同时使用不同来源的connector时,必须按照对应connector文档提供的指南来设置相应的配置选项。

所以,即使目标都是Doris,但基于Flink CDC的不同connector实现版本,用户可能需要根据所选用的connector重新定义相关的options配置。这有助于确保正确解析和应用配置信息到对应的connector实例上。



关于本问题的更多回答可点击进行查看:

https://developer.aliyun.com/ask/597940?spm=a2c6h.12873639.article-detail.85.50e24378TRW91E



问题五:Flink CDC里那binlog 过期 怎么处理呢?

Flink CDC里那binlog 过期 怎么处理呢?



参考答案:

增加binlog 保留时间,或者增加并发加快全量同步,反正全量结束后,可以将并发改成1重启的。



关于本问题的更多回答可点击进行查看:

https://developer.aliyun.com/ask/597939?spm=a2c6h.12873639.article-detail.86.50e24378TRW91E

相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
相关文章
|
1月前
|
消息中间件 Java Kafka
Flink CDC 在外部查询某个 job 中的表数据
【2月更文挑战第27天】Flink CDC 在外部查询某个 job 中的表数据
44 5
|
1月前
|
API 数据库 流计算
有大佬知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作,重启服务之后目标表能进行对源表删除的数据进行删除吗?
【2月更文挑战第27天】有大佬知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作,重启服务之后目标表能进行对源表删除的数据进行删除吗?
52 3
|
29天前
|
SQL 存储 API
阿里云实时计算Flink的产品化思考与实践【下】
本文整理自阿里云高级产品专家黄鹏程和阿里云技术专家陈婧敏在 FFA 2023 平台建设专场中的分享。
110822 100
阿里云实时计算Flink的产品化思考与实践【下】
|
1月前
|
自然语言处理 Java Scala
Flink CDC产品常见问题之大文件整库同步怎么解决
Flink CDC产品常见问题之大文件整库同步怎么解决
|
1月前
|
消息中间件 Kafka 流计算
如果有多个版本的Flink CDC在同一环境中运行,可能会导致Debezium版本冲突
【2月更文挑战第30天】如果有多个版本的Flink CDC在同一环境中运行,可能会导致Debezium版本冲突
20 2
|
1月前
|
消息中间件 API Apache
官宣|阿里巴巴捐赠的 Flink CDC 项目正式加入 Apache 基金会
本文整理自阿里云开源大数据平台徐榜江 (雪尽),关于阿里巴巴捐赠的 Flink CDC 项目正式加入 Apache 基金会。
1416 1
官宣|阿里巴巴捐赠的 Flink CDC 项目正式加入 Apache 基金会
|
1月前
|
Java 关系型数据库 MySQL
Flink CDC有见这个报错不?
【2月更文挑战第29天】Flink CDC有见这个报错不?
22 2
|
19天前
|
存储 安全 关系型数据库
Mysql 的binlog日志的优缺点
MySQL的binlog(二进制日志)是一个记录数据库更改的日志文件,它包含了所有对数据库执行的更改操作,如INSERT、UPDATE和DELETE等。binlog的主要目的是复制和恢复。以下是binlog日志的优缺点: ### 优点: 1. **数据恢复**:当数据库出现意外故障或数据丢失时,可以利用binlog进行点恢复(point-in-time recovery),将数据恢复到某一特定时间点。 2. **主从复制**:binlog是实现MySQL主从复制功能的核心组件。主服务器将binlog中的事件发送到从服务器,从服务器再重放这些事件,从而实现数据的同步。 3. **审计**:b
|
28天前
|
SQL 关系型数据库 MySQL
mysql的binlog恢复数据
mysql的binlog恢复数据
29 0
|
2月前
|
存储 SQL 安全
浅谈MySQL Binlog
浅谈MySQL Binlog
45 0

相关产品

  • 实时计算 Flink版