（一） flink 1.11.2 下载地址 ：
https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.11.2/python/apache_flink-1.11.2-cp37-cp37m-manylinux1_x86_64.whl
https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.11.2/
( 二) 关联包
下载以下依赖 jar 包，并拷贝到 flink-1.11.0/lib/ 目录下。因为我们运行时需要依赖各个 connector 实现。可以在GitHub上面下载 https://github.com/peigenxiao/my-flink-project/tree/master/flinklib
（三）设置
export FLINK_HOME=/home/hadoop/flink-1.11.2 export PATH=$PATH:$HADOOP_HOME/bin source /etc/profile # sh /home/hadoop/flink-1.11.2/bin/start-cluster.sh export FLINK_HOME=/home/hadoop/flink-1.11.2 cd /home/hadoop/flink-1.11.2/conf/flink-conf.yaml vi flink-conf.yaml jobmanager.rpc.address:master rest.port: 8091 #8091端口设置后不起作用？ #jobmanager.memory.process.size: 300m #taskmanager.memory.process.size: 300m vi master master:8091 vi workers slave1 slave2 scp -r /home/hadoop/flink-1.11.2/ hadoop@slave1:/home/hadoop/ scp -r /home/hadoop/flink-1.11.2/ hadoop@slave2:/home/hadoop/ scp /home/hadoop/flink-1.11.2/conf/flink-conf.yaml hadoop@slave1:/home/hadoop/flink-1.11.2/conf/
（四）测试
cd /home/hadoop/flink-1.11.2/bin
启动
start-cluster.sh
./flink run /home/hadoop/flink-1.11.2/examples/streaming/WordCount.jar
登录web控制台查看结果。
http://192.168.91.112:8091
停止 start-cluster.sh
（五）CDC 测试使用：
Flink1.11中的CDC Connectors操作实践 【https://blog.csdn.net/jmx_bigdata/article/details/107993482】
Flink 1.11 SQL 使用攻略 【 https://www.jianshu.com/p/8f2a40ec226d】
flink 1.11 sqlclint 官方文档【https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sqlClient.html#environment-files】
Hive Integration 【https://ci.apache.org/projects/flink/flink-docs-master/dev/table/hive/】
Hive Read & Write 【https://ci.apache.org/projects/flink/flink-docs-master/dev/table/hive/hive_read_write.html】
hive与flink的流批一体设计方式【https://mp.weixin.qq.com/s?__biz=MzU3Mzg4OTMyNQ==&mid=2247489376&idx=1&sn=000fda2c695c88a6542f5cebb3207b64&chksm=fd3b9922ca4c1034b8bc0bff6d091c31c13b41443c3a71f5420007d91bc24b60bb102d6a9a94&xtrack=1&scene=90&subscene=93&sessionid=1601205791&clicktime=1601205953&enterid=1601205953&ascene=56&devicetype=android-26&version=3.0.31.2998&nettype=cmnet&abtest_cookie=AAACAA%3D%3D&lang=zh_CN&exportkey=AeaDMVfzSL04VBtRUGcfL2Q%3D&pass_ticket=%2BVHG5JT6TAPRJ0%2BEgPbDiMJd0tzudJm5cBMmrmzu1D1RF1aDyY2nyEIuVQLSQS23&wx_header=1&platform=win】
flink 先加载 child class的设置【https://blog.csdn.net/weixin_44904816/article/details/108250776】