下载flink-1.9.3-bin-scala_2.11.tgztar -xzvf flink-1.9.3-bin-scala_2.11.tgz配置相关参数2.1 flink-conf.yaml2.2 masters2.3 slaves分发到其他节点scp -r /home/xtdsj/bigdata/flink root@cdh-worker1:/home/xtdsj/bigdata启动flin

master节点cd /opt/bigdata/hadoop/hadoop-3.2.0/sbin./stop-all.sh然后三个节点都进行cd /opt/bigdata/hadooprm -rf dfs/*mkdir -p dfs/datamkdir -p dfs/namecd /opt/bigdata/hadoop/hadoop-3.2.0/etc/hadoopvi yarn-site.xml

canal同步mysql数据到ES前提是：mysql开启了bingo日志canal的原理是模拟自己为mysql slave，所以这里一定需要做为mysql slave的相关权限.CREATE USER canal IDENTIFIED BY 'Mmc..5211314';GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *...

pom文件加入启动依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency>yml文件配置前缀 后缀 关闭缓存...