1. 本际云推荐 - 专业推荐VPS、服务器，IDC点评首页
  2. 云主机运维
  3. VPS运维

Flink1.11.1的StandaloneSessionClusterEntrypoint模式部署

小编小本本 • • VPS运维

Flink1.11.1的StandaloneSessionClusterEntrypoint模式部署

介绍

作为一名本际云服务器推荐网的小编，今天为大家介绍Flink1.11.1的StandaloneSessionClusterEntrypoint模式部署。

部署步骤

环境信息

我们的环境中有三台机器，其中ip为103、104、105，主节点为103，其它为从节点。主机信息如下表格：

JobManager/TaskManager TaskManager TaskManager
192.168.199.103/bigdata-04 192.168.199.104/bigdata-05 192.168.199.105/bigdata-06
Master/Slave Slave Slave

安装

首先，我们需要下载Flink安装压缩包。下载完成后，放到103主节点机器的/home/gpadmin/目录下，并解压安装。安装命令如下：

tar -zvxf flink-1.11.1-bin-scala_2.11.tgz -C /home/gpadmin/
cd /home/gpadmin/
ln -sv flink-1.11.1/ flink

修改配置文件flink-conf.yaml，如下内容：

jobmanager.rpc.address: bigdata-04
jobmanager.rpc.port: 6123
jobmanager.heap.size: 1024m
taskmanager.heap.size: 1600m
taskmanager.numberOfTaskSlots: 8
parallelism.default: 1

修改masters文件为bigdata-04:8081，修改slaves文件为bigdata-04，bigdata-05，bigdata-06。分发文件以及配置到其它两台机器：

scp -r /home/gpadmin/flink bigdata-05:/home/gpadmin/
scp -r /home/gpadmin/flink bigdata-06:/home/gpadmin/

启动

进入主节点/flink/bin，执行以下命令启动集群：

./start-cluster.sh

进入UI界面http://192.168.199.103:8081，点击Submit New Job功能，添加要运行的jar包，输入主程序的路径即可提交作业。通过TaskManager可以找到任务的控制台，可以看到输出。停止作业的方式也非常简单，直接在UI界面上点击Stop按钮即可。

结尾

至此，Flink1.11.1的StandaloneSessionClusterEntrypoint模式部署，以及UI界面提交jar包和作业模式、停止作业等就全部完成了。希望这篇文章对您有所帮助。

原创文章，作者：小编小本本，如若转载，请注明出处：https://www.benjiyun.com/yunzhujiyunwei/vps-yunwei/5995.html

赞 (0)
小编小本本小编小本本
« 上一篇 2023年4月16日 am8:00
下一篇 » 2023年4月16日 am8:00

相关推荐