Flink单节点部署,flink standalone deploy
Flink单节点部署测试
官网下载最新压缩包 https://nightlies.apache.org/flink, 这里选择 版本 flink-1.14.2 scala-2.11版本
检查服务器已配置 jdk环境以及 无秘钥通信
修改配置文件
cd flink-1.14.2/conf
vim flink-conf.yaml
增加配置项
### jdk
env.java.home: /mysoft/jdk1.8.0_161
#job task memory
jobmanager.rpc.address: 192.168.29.160
jobmanager.rpc.port: 6123
taskmanager.memory.process.size: 1000m
jobmanager.memory.process.size: 1000m
### rest conf
rest.port: 8888
rest.address: 192.168.29.160
##rest.bind-port: 8080-8090
rest.bind-port: 8888
rest.bind-address: 192.168.29.160
### web ui upload
##The address to which the REST client will connect to
web.submit.enable: true
web.upload.dir: /mysoft/flink-1.14.2/jobjar
io.tmp.dirs: /mysoft/flink-1.14.2/tmp
创建目录
cd flink-1.14.2
mkdir -p /mysoft/flink-1.14.2/jobjar //upload jar location
mkdir -p /mysoft/flink-1.14.2/tmp
配置完成 启动服务
cd flink-1.14.2/bin
./start-cluster.sh
检查进程
访问 flink-web ui : http://192.168.29.160:8888
进入flink-sql交互界面
./sql-client.sh
发表评论
取消回复