首页 > 其他分享 >单机单节点Flink的部署

单机单节点Flink的部署

时间:2023-04-21 14:23:09浏览次数:46  
标签:opt Flink 单机 flink module 1.15 节点

一、Flink的下载和安装

1、Flink的下载

官方下载网址:https://archive.apache.org/dist/flink/
这里选择1.15.2这个版本

 

2、把Flink上传到主机上

把下载好的文件上传到/opt/software

3、解压Flink安装包

把Flink解压到/opt/module中,要提前创建module文件夹

tar -zxvf flink-1.15.2-bin-scala_2.12.tgz -C /opt/module

二、配置Flink

1、配置环境变量

vi /etc/profile
在下面加上
#FLINK_HOME
export FLINK_HOME=/opt/module/flink-1.15.2
export PATH=$PATH:$FLINK_HOME/bin

source /etc/profile

2、修改Flink配置文件

cd /opt/module/flink-1.15.2/conf
vim flink-conf.yaml

flink单节点部署的话只需要修改一个地方

rest.bind-address: 0.0.0.0 (默认是localhost)

 

 

3、启动Flink

因为已经配置了环境变量所以直接用start-cluster.sh就可以启动flink

 直接访问http://bigdata01:8081即可以进入Flink的WEB UI,可以对 flink 集群和任务进行监控管理
注:使用bigdata01需要在原主机配置hosts,否则你只能使用ip:8081进行访问

 ***注:单节点部署Flink就是不搭建集群,直接本地启动。本地部署非常简单,一般只用来做一些简单的测试***。

 

标签:opt,Flink,单机,flink,module,1.15,节点
From: https://www.cnblogs.com/qsds/p/17340191.html

相关文章

  • leetcode-876链表的中间节点
    找链表的中间节点思路心得当不知道while的终止条件时,可以先写while(true),然后在循环体中写终止条件,这样写的好处是可以暂时不考虑终止条件,使思路更清晰;坏处是这样有时候会使循环体的内容很混乱要注意分类!本题中把情况分为节点个数是奇数和偶数去分析,最终找到统一的......
  • JavaScript的节点操作
    目录节点概述节点层级添删等节点操作使用节点操作的示例节点概述一般来说,节点至少拥有nodeType,nodeName,nodeValue这三个基本属性1.元素节点的nodeType为12.属性节点的nodeType为23.文本节点的nodeType为3(包括换行,文字,空格)节点层级1.父节点:node.parentNode(1)paren......
  • Linux设备节点创建方式的演变历史
    引子  遵从"Everythingisafile"的思想,在Linux下想要操作设备的话,是需要通过一类叫做设备节点(devicenode)的特殊文件。设备节点通常位于/dev这个目录下,但是位于其它目录也是可以的。只要翻开一本介绍Linux驱动的书,或者在网上搜索相关的文章,很大概率上会教你在写好驱动代码后......
  • CF 580C- Kefa and Park, 1500 / 树的遍历 / 根节点到叶节点的路径上某性质的点不能
    CF580C-KefaandPark这个1500的题这么水?这还不如1200、1300的思维题我开始没考虑周全,这题给出的连边没有讲都是从父节点连向子节点,所有要建双边。#include<iostream>#include<cstring>usingnamespacestd;constintN=1e5+10,M=N*2;typedeflonglon......
  • 每个节点上的cadvisor采集数据后通过aggregate api将转换交给 metric-server
    metric-server主要用来通过aggregateapi向其它组件(kube-scheduler、HorizontalPodAutoscaler、Kubernetes集群客户端等)提供集群中的pod和node的cpu和memory的监控指标,弹性伸缩中的podautoscaler就是通过调用这个接口来查看pod的当前资源使用量来进行pod的扩缩容的。需要注意的是......
  • JZ18 删除链表的节点
    importjava.util.*;/**publicclassListNode{*intval;*ListNodenext=null;*publicListNode(intval){*this.val=val;*}*}*/publicclassSolution{/***代码中的类名、方法名、参数名已经指定,请勿修改,直接返回方法......
  • SchemaRegestry组件原生的类和方法无法实现flink消费kafka的数据动态调整schema的情况
    0、前提知识储备Conflurent公司的SchemaRegestry组件的基本了解和使用一、背景:0.组件版本flink:1.141.链路调整情况原先链路:oracle-->OGG-->kafka-->flink-->数据库\湖\仓实现链路:oracle-->OGG-->kafka(搭配conflurent公司的SchemaRegestry组件使用)-->flink-->数据库\湖\仓2......
  • jquery遍历节点
    <table><tbody><tr><td><table><tbody><trclass="s">......
  • 动力节点2023版MyBatisPlus教程【进阶篇】
    来自B站动力节点最新版的MybatisPlus教程,整理了笔记——第四章高级篇4【高级篇】4.1主键策略4.1.1主键生成策略介绍首先大家先要知道什么是主键,主键的作用就是唯一标识,我们可以通过这个唯一标识来定位到这条数据。当然对于表数据中的主键,我们可以自己设计生成规则,生成主键。......
  • LInux单机部署ELK日志收集
    LInux单机部署ELK日志收集一、环境准备centos7cpu:1核内存:8G#安装vim,wget,net-tools设置主机名:vim/etc/hosts127.0.0.1localhostlocalhost.localdomainlocalhost4localhost4.localdomain4::1localhostlocalhost.localdomainlocalhost6localhost6.local......