代码拉取完成,页面将自动刷新
下载
官网下载
解压
tar -zxvf flink-1.10.1-bin-scala_2.11.tgz -C /opt
配置环境变量
# flink
export FLINK_HOME=/opt/flink-1.10.1
export PATH=$FLINK_HOME/bin:$PATH
查看flink版本
flink -v
配置flink配置文件
cd $FLINK_HOME/conf
vim flink-conf.yaml
flink-conf.yaml
# 指定jobmanager的地址(可用ip/别名)
jobmanager.rpc.address: master
# 每个jobmanager的可用内存
jobmanager.heap.size:1024m
# 每个taskmanager的可用内存
taskmanager.memory.process.size: 1728m
# 每台计算机可用的CPU核数
taskmanager.numberOfTaskSlots: 12
# 集群中的CPU总数
parallelism.default: 72
# 临时目录
io.tmp.dirs: /opt/flink-1.10.1/tmp
查看逻辑cpu的个数
cat /proc/cpuinfo|grep "processor"| wc -l
slaves
# 指定taskmanager的所在节点
slave01
slave02
分发
scp -r -P 2222 /opt/flink-1.10.1 root@slave01:/opt
scp -P 2222 ~/.bash_profile root@slave01:~/.bash_profile
由于在flink-conf.yaml中修改了临时文件路径配置项io.tmp.dirs,它不会自动创建,需要手动创建。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。