首页 > 其他分享 >flink集群安装-Standalone模式

flink集群安装-Standalone模式

时间:2022-10-28 21:47:13浏览次数:79  
标签:1.13 Standalone flink 192.168 TaskManager 集群 conf 安装

1、节点规划

JobManager: 192.168.23.151
TaskManager:192.168.23.152
TaskManager:192.168.23.153
TaskManager:192.168.23.154

2、安装配置

1)首先在一台机器上安装flink,参考flink本地开发环境安装与部署(单机)

2)修改flink-conf.yaml

vi flink-1.13.0/conf/flink-conf.yaml
jobmanager.rpc.address: 192.168.23.151(这一行修改成机器IP)

3)修改master

vi flink-1.13.0/conf/masters
192.168.23.151:8081(内容是JobManager的IP:端口)

4)修改workers

vi flink-1.13.0/conf/workers
192.168.23.152(内容是3个TaskManager的IP)
192.168.23.153
192.168.23.154

5)将151节点安装配置好的flink复制到其它3台机器

scp -r ./flink-1.13.0 192.168.23.152://usr/local/myroom/
scp -r ./flink-1.13.0 192.168.23.153://usr/local/myroom/
scp -r ./flink-1.13.0 192.168.23.154://usr/local/myroom/

3、部署测试

1)启动

start-cluster.sh

2)部署,参考flink本地开发环境安装与部署(单机)

3)测试,参考flink本地开发环境安装与部署(单机)

4)页面展示

 

标签:1.13,Standalone,flink,192.168,TaskManager,集群,conf,安装
From: https://www.cnblogs.com/javasl/p/16833225.html

相关文章

  • Istio(二):在Kubernetes(k8s)集群上安装部署istio1.14
    目录一.模块概览二.系统环境三.安装istio3.1使用Istioctl安装3.2使用IstioOperator安装3.3生产部署情况如何?3.4平台安装指南四.GetMesh4.1如何开始使用?4.2如何......
  • iceberg flink 读操作
    org.apache.iceberg.flink.source.FlinkInputFormat.open@Overridepublicvoidopen(FlinkInputSplitsplit){//split.getTask().files():FlinkInputSplit.CombinedS......
  • Zookeeper - ZAB 集群数据同步的过程
    Zookeeper事务ID每个zookeeper事务都有一个全局唯一的事务ID,ZXID。ZXID高32位是leader周期epoch,低32位是递增计数器。第一阶段(准leader生成初始化事务集合)所有......
  • iceberg flink 写操作
    org.apache.iceberg.io.PartitionedFanoutWriter#writepublicvoidwrite(Trow)throwsIOException{//org.apache.flink.table.data.RowData->org.apache.iceberg......
  • Clickhouse之集群操作
    查看集群:在任意一台机上,使用/usr/bin/clickhouse-client--hostlocalhost--port9000连接本地服务器select*from`system`.clusters; 建库:建库create......
  • Elasticsearch 集群健康值红色解决方法
    通过http://10.2.83.29:9100/查询集群状态为红色,说明部分主分片不可用head插件会以不同的颜色显示。绿色——最健康的状态,代表所有的主分片和副本分片都可用;黄色——所......
  • 在 Kubernetes 集群中部署现代应用的通用模式
    在Kubernetes集群中部署现代应用的通用模式摘要我们正在经历现代应用交付领域的第二次浪潮,而Kubernetes和容器化则是这次浪潮的主要推动力量。随着第二次浪潮的推进,......
  • redis集群手动切换主从
    生产环境一个三主三从,其中一个主节点挂掉了,但是没有自动切换到从节点cluster-require-full-coverage默认为yes,当集群中一段槽位的主从都不可用时,整个集群不提供服务直接导致......
  • Flink之状态编程
    状态编程是Flink最出色的功能没有之一一、什么是状态?在流式计算中有些操作一次处理一个独立的事件(比如解析一个事件),有些操作却需要记住多个事件的信息(比如窗口操作)......
  • ES集群检查常用命令
    一、集群检查常用命令查询集群状态命令:curl-XGET"http://ip:port/_cluster/health?pretty"查询Es全局状态:curl-XGET"http://ip:port/_cluster/stats?pretty"......