第六章 实时数仓专题之flink local模式安装（flink 1.13.1安装包见文末）

第六章 实时数仓专题之flink local模式安装（flink 1.13.1安装包见文末） 1、将文件上传到虚拟机上解压

tar -zxvf flink-1.13.1-bin-scala_2.12.tgz -C /opt/module

2、配置flink-conf.yaml文件

vim flink-conf.yaml

#配置jobmanager内存大小
jobmanager.memory.process.size: 1600m

#配置taskmanager内存大小
taskmanager.memory.process.size: 1728m

#配置slot的个数
taskmanager.numberOfTaskSlots:4

3、本地模式启动flink

bin/start-cluster.sh

4、local模式提交JOB

（1）创建文件

vim /opt/module/flink-1.13.1/data/source.txt

（2）命令行模式提交JOB

./flink run /opt/module/flink-1.13.1/examples/batch/WordCount.jar --input /opt/module/flink-1.13.1/data/source.txt --output /opt/module/flink-1.13.1/data/result.txt

• 查看运行日志

附件：资源附件

链接：https://pan.baidu.com/s/1fr92UCMdfbeKV8AfrDIVWA 
提取码：bt0e