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

Flink搭建

目录

一、standalone模式

二、Flink on Yarn模式


一、standalone模式

  1. 解压安装Flink

[root@bigdata1 software]# tar -zxvf flink-1.14.0-bin-scala_2.12.tgz -C /opt/module/
[root@bigdata1 module]# mv flink-1.14.0/ flink-standalone

     2.进入conf修改flink-conf.yaml

jobmanager.rpc.address: bigdata1

        3.修改wokers

[root@bigdata1 conf]# vim workers
bigdata1
bigdata2
bigdata3

        4.分发到集群其他节点

[root@bigdata1 module]# rsync -av /opt/module/flink-standalone/ bigdata2:/opt/module/flink-standalone/
[root@bigdata1 module]# rsync -av /opt/module/flink-standalone/ bigdata3:/opt/module/flink-standalone/

        5.启动Flink集群命令

[root@bigdata1 flink-standalone]# bin/start-cluster.sh
 

        6.访问http://主机:8081可以对flink集群和任务进行监控  

         http://bigdata1:8081

         7.停止Flink集群命令

bin/stop-cluster.sh

二、Flink on Yarn模式

        1.解压安装

[root@bigdata1 software]# tar -zxvf /opt/software/flink-1.14.0-bin-scala_2.12.tgz -C /opt/module/
[root@bigdata1 module]# mv flink-1.14.0/ flink-yarn

        2.配置环境变量

        vim /etc/profile

#配置环境变量HADOOP_CLASSPATH, 如果前面已经配置可以忽略。
#export HADOOP_CLASSPATH=`hadoop classpath`
#FLINK_HOME
export FLINK_HOME=/opt/module/flink-yarn
export PATH=$PATH:$FLINK_HOME/bin
export HADOOP_CLASSPATH=`hadoop classpath`
export HADOOP_CONF_DIR=${HADOOP_HOME}/etc/hadoop

        3.启动Hadoop集群

        Flink on yarn 基于Hadoop集群的yarn

相关文章:

  • 【LeetCode】二叉树oj专题
  • elementplu父级页面怎么使用封装子组件原组件的方法
  • 【距离四六级只剩一个星期!】刘晓艳四级保命班课程笔记(2)(可分享治资料~)
  • 前端 html格式转md格式插件使用介绍
  • 解决JSON.stringify 方法在序列化 BigInt 类型时的错误
  • ardupilot开发 --- 机载计算机-软件方案 篇
  • 基于单片机的超声波倒车雷达设计
  • 汇舟问卷:国外问卷调查怎么样?
  • mysql like 查询优化
  • 遥感卫星影像处理流程
  • 3403(3519Dv500)算子精度比对工具标杆数据生成环境搭建指导(Caffe)
  • 【Python Cookbook】S01E15 将名称映射到序列的元素中
  • Next.js API Routes:构建服务端功能
  • vue限制日期选择器不能选今年后的日期
  • Unity开发——编辑器打包、3种方式加载AssetBundle资源
  • 【翻译】Mashape是如何管理15000个API和微服务的(三)
  • 【每日笔记】【Go学习笔记】2019-01-10 codis proxy处理流程
  • android百种动画侧滑库、步骤视图、TextView效果、社交、搜房、K线图等源码
  • git 常用命令
  • JDK 6和JDK 7中的substring()方法
  • MD5加密原理解析及OC版原理实现
  • orm2 中文文档 3.1 模型属性
  • Python中eval与exec的使用及区别
  • 服务器之间,相同帐号,实现免密钥登录
  • 关于字符编码你应该知道的事情
  • 和 || 运算
  • 基于Javascript, Springboot的管理系统报表查询页面代码设计
  • 开放才能进步!Angular和Wijmo一起走过的日子
  • 驱动程序原理
  • 如何设计一个比特币钱包服务
  • 体验javascript之美-第五课 匿名函数自执行和闭包是一回事儿吗?
  • 译有关态射的一切
  • 用 vue 组件自定义 v-model, 实现一个 Tab 组件。
  • ​【原创】基于SSM的酒店预约管理系统(酒店管理系统毕业设计)
  • ​MPV,汽车产品里一个特殊品类的进化过程
  • ​软考-高级-信息系统项目管理师教程 第四版【第23章-组织通用管理-思维导图】​
  • # 数据结构
  • #1014 : Trie树
  • $GOPATH/go.mod exists but should not goland
  • (3)(3.2) MAVLink2数据包签名(安全)
  • (7)STL算法之交换赋值
  • (AngularJS)Angular 控制器之间通信初探
  • (HAL库版)freeRTOS移植STMF103
  • (Matalb回归预测)PSO-BP粒子群算法优化BP神经网络的多维回归预测
  • (pojstep1.3.1)1017(构造法模拟)
  • (pytorch进阶之路)CLIP模型 实现图像多模态检索任务
  • (附源码)springboot电竞专题网站 毕业设计 641314
  • (附源码)ssm航空客运订票系统 毕业设计 141612
  • (黑客游戏)HackTheGame1.21 过关攻略
  • (九十四)函数和二维数组
  • (六)什么是Vite——热更新时vite、webpack做了什么
  • (十八)用JAVA编写MP3解码器——迷你播放器
  • (原创)攻击方式学习之(4) - 拒绝服务(DOS/DDOS/DRDOS)
  • (转)c++ std::pair 与 std::make
  • . ./ bash dash source 这五种执行shell脚本方式 区别