在日常的大数据场景里面,我们经常会涉及到使用flink-cdc把源数据同步到数据仓库或者数据湖中,所以这里我们演示一下使用flink-cdc把mysql的数据同步到doris中。下面直接开始:
一、前置条件
这里我们演示使用的版本号如下:
1、mysql版本:5.7 2、doris版本:2.1.7 3、flink版本:1.20.0
二、部署mysql
这里部署mysql比较简单主要是需要开启binlog,详见:
三、部署flink
如果你有一个flink集群的话,就尅直接使用,如果你没有的话直接下载一个包,解压缩后进入到bin目录直接./start-cluster.sh启动一个单机版本即可,不需要任何其他配置。
发表评论