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

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

vim flink-conf.yaml

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

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

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

bin/start-cluster.sh

（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