当前位置: 首页 > news >正文

大数据flink篇之三-flink运行环境安装(一)单机Standalone安装

一、安装包下载地址
https://archive.apache.org/dist/flink/flink-1.15.0/
在这里插入图片描述
二、安装配置流程
前提基础:Centos环境(建议7以上)
安装命令:
解压:tar -zxvf flink-xxxx.tar.gz
修改配置conf/flink-conf.yaml:
jobmanager.rpc.address: 192.168.47.131-主机地址
jobmanager.rpc.port: 6123
taskmanager.numberOfTaskSlots: 4
rest.port: 8081
配置类参数
在这里插入图片描述
**部分配置解析如下:
jobmanager.rpc.address: localhost-主机名
jobmanager.rpc.port: 6123-主机通信端口号
jobmanager.heap.size: 1024m-jvm 堆内存
taskmanager.memory.process.size: 1728m-当前 taskmanager 进程的堆内和堆外内存等(与 flink.size 相比,多了一些不在flink 状态管理的堆外内存)
taskmanager.numberOfTaskSlots: 1-静态分配属性资源
parallelism.default: 1-运行时的并行度,默认

启动flink:
./bin/start-cluster.sh
启动的进程为:
在这里插入图片描述
三、Web界面
安装成功后会显示如下界面:
在这里插入图片描述
后续会补充集群版本及在yarn和k8s环境下的部署。
注:如果在虚拟机上安装,需要开放相关端口
firewall-cmd --zone=public --permanent --add-port=8081/tcp:开启端口8081
firewall-cmd --reload:重载防火墙

http://www.lryc.cn/news/194024.html

相关文章:

  • Redisson使用延时队列
  • 基于php 进行每半小时钉钉预警
  • 5.Python-使用XMLHttpRequest对象来发送Ajax请求
  • 八皇后问题的解析与实现
  • 论文浅尝 | 深度神经网络的模型压缩
  • 进阶JAVA篇- DateTimeFormatter 类与 Period 类、Duration类的常用API(八)
  • 1.1 Windows驱动开发:配置驱动开发环境
  • Jetpack:009-kotlin中的lambda、匿名函数和闭包
  • openGauss指定schema下全部表结构备份与恢复
  • 干货:如何在前端统计用户访问来源?
  • 李宏毅生成式AI课程笔记(持续更新
  • nodejs+vue+elementui酒店客房服务系统mysql带商家
  • 【网络协议】聊聊网络分层
  • [开源]基于Vue+ElementUI+G2Plot+Echarts的仪表盘设计器
  • html设置前端加载动画
  • 【git的使用方法】——上传文件到gitlab仓库
  • Kafka 开启SASL/SCRAM认证 及 ACL授权(二)ACL
  • Java8 新特性之Stream(三)-- Stream的终结操作
  • 【Vue面试题二十八】、vue要做权限管理该怎么做?如果控制到按钮级别的权限怎么做?
  • 1、验证1101序列(Moore)
  • Java基础面试-BeanFactroy和ApplicationContext
  • js的入口函数
  • [cpp primer随笔] 10. 函数重载与重载决议
  • java_Stream API
  • 红队专题-工具Fscan
  • 【宏实现二进制奇偶位交换】
  • 【Java零基础入门到就业】第一天:java简介和cmd窗口的一些常见命令
  • ubuntu下yolov5 tensorrt模型部署
  • windows Vscode 连接 虚拟机,超详细,含免密免ip配置 以 linux 虚拟机为例
  • 【Unity】VR基础开发2项目准备-VR基本场景构建(OpenXR方向)