1.环境介绍Flink1.17+Flinkcdc2.2.12.问题描述使用Flink1.17和Flinkcdc2.2.1环境进行数据加工，但是报以上错误，原因是版本不匹配，flinkcdc2.2.1用的是guava18，但是flink1.17用的是guava30，导致冲突。3.问题解决添加flink-sql-connector-mysql-cdc依赖<dependen

大数据技术涉及组件较多，各个环境较DEMO又不尽相同，所以参照DEMO进行，任然很多报错信息出现。如下报错处理，尽供参考：1.创建同步配置文件################################################################################Description:SyncMySQLalltablestoDoris#########

业务痛点离开了业务谈技术都是耍流氓。我们来聊聊基于业务的痛点，衍生出来的多种数据同步方案。业务中常见的需要数据同步的场景1、多个库的表合并到一张表。不同的业务线或者微服务在不同的数据库里开发，但是此时有些报表需要将多个库的类似的数据合并后做查询统计。或者，某些历

架构图大致如下：版本信息大致如下，具体版本信息根据自己的需求进行调整即可：oracle：19cflinkcdc：2.4.0kafka：3.1.2flink：1.15.4mysql：8.0.27springboot：2.5.6实现需求：1.使用flinkcdc采集oracle中的数据（历史数据+增量数据：含增删改）同步至kafka的某个topic中2.使用flink消费kafka中

报错一：原因分析：字面原因，找不到 org.apache.flink.table.api.ValidationException类。解决办法：根据类名可知，应该 org.apache.flink.table.api包下面的，然后去阿里云maven仓库搜索，添加如下依赖即可 报错二：原因分析：ORA-16331:容器"ORCLPDB1"未打开。解决办法：使用命令打

FlinkCDC的自定义反序列化FlinkCDC的简单使用方法packagecom.pzb;importcom.ververica.cdc.connectors.mysql.MySqlSource;importcom.ververica.cdc.connectors.my

目录作用app产生各层数据的flink任务bean数据对象common公共常量utils工具类app.ods.FlinkCDC.javapackagecom.atguigu.app.ods;import

CDCCDC是ChangeDataCapture(变更数据获取)的简称。核心思想是，监测并捕获数据库的变动（包括数据或数据表的插入、更新以及删除等），将这些变更按发生的顺序完整记录下来，写

目录一、概述二、Hudi数据管理1）.hoodie文件2）数据文件三、数据存储四、Hive与Hudi集成使用1）安装mysql数据库2）安装Hive1、下载2、配置3、解决Hive与Hadoop之间guava版本