flink单节点部署 standalone model deploy

Flink单节点部署,flink standalone deploy

Flink单节点部署测试

官网下载最新压缩包 https://nightlies.apache.org/flink, 这里选择 版本 flink-1.14.2 scala-2.11版本
检查服务器已配置 jdk环境以及 无秘钥通信

linux下jdk环境变量
ssh无秘钥通信配置

修改配置文件
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集群启动

检查进程

flink进程检查
访问 flink-web ui : http://192.168.29.160:8888
flink webui访问

./sql-client.sh

flink-sql交互界面

上一篇 下一篇


推荐文章

评论
说点什么吧?

发表评论

取消回复
  最新文章