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

【极数系列】Flink环境搭建Linux版本 (03)

文章目录

  • 引言
  • 01 Linux部署JDK11版本
    • 1.下载Linux版本的JDK11
      • 2.创建目录
      • 3.上传并解压
      • 4.配置环境变量
      • 5.刷新环境变量
      • 6.检查jdk安装是否成功
  • 02 Linux部署Flink1.18.0版本
      • 1.下载Flink1.18.0版本包
      • 2.上传压缩包到服务器
      • 3.修改flink-config.yaml配置
      • 4.启动服务
      • 5.浏览器访问
      • 6.停止服务

引言

Jdk版本: 11
Flink版本: 1.18.0
Linux版本: Centos 7.5.6

01 Linux部署JDK11版本

1.下载Linux版本的JDK11

版本:jdk-11.0.2_linux-x64_bin.tar.gz

https://repo.huaweicloud.com/java/jdk/

2.创建目录

mkdir /usr/java

3.上传并解压

cd /usr/java
rz jdk-11.0.2_linux-x64_bin.tar.gz
tar -xzvf jdk-11.0.2_linux-x64_bin.tar.gz
解压后目录:/usr/java/jdk-11.0.2

4.配置环境变量

vi /etc/profile
#把下面三行加到文件末尾
export JAVA_HOME=/usr/java/jdk-11.0.2
export CLASSPATH=$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib
export PATH=$JAVA_HOME/bin:$PATH

5.刷新环境变量

source /etc/profile

6.检查jdk安装是否成功

看到版本即可 java -version

02 Linux部署Flink1.18.0版本

1.下载Flink1.18.0版本包

地址:https://www.apache.org/dyn/closer.lua/flink/flink-1.18.0/flink-1.18.0-bin-scala_2.12.tgz

2.上传压缩包到服务器

cd /www
rz flink-1.18.0-bin-scala_2.12.tgz
tar -xvf flink-1.18.0-bin-scala_2.12.tgz

3.修改flink-config.yaml配置

tips:修改这个配置主要是为了外部网络可以访问,否则只能本地访问

vi /www/flink-1.18.0/conf/flink-config.yaml
把这个配置#rest.bind-address: 0.0.0.0前面的#去掉,如果value是localhost则改为0.0.0.0

在这里插入图片描述

4.启动服务

cd /www/flink-1.18.0
./bin/start-cluster.sh

5.浏览器访问

flinkUI地址:http://127.0.0.1:8081

注意云服务器可能需要关闭对应的防火墙或者是开发端口

#通过命令查看防火墙策略
sudo iptables -L | more
#如果输出内容为Chain INPUT (policy DROP),再执行修改策略
sudo iptables -P INPUT ACCEPT
#直到确认输出为Chain INPUT (policy ACCEPT),才可清除所有规则停止防火墙
sudo iptables -F 
#关闭防火墙
systemctl stop firewalld.service

6.停止服务

cd /www/flink-1.18.0
./bin/stop-cluster.sh

相关文章:

  • linux 云主机扩展磁盘的步骤
  • win11 蓝屏分析,没有一定的原因,没有解决办法,只能不断尝试
  • 常用命令-
  • 内置函数和推导式
  • 83.网游逆向分析与插件开发-背包的获取-自动化助手显示装备数据
  • FPGA硬件架构
  • 第26讲:顺序表的应用(通讯录)
  • 人工智能与机器学习——开启智能时代的里程碑
  • JavaEE-自定义SSM-编写核心- my spring bean工厂(IoC、DI)
  • MySQL库表操作 作业
  • C语言基础13
  • HarmonyOS 鸿蒙应用开发 (七、HTTP网络组件 axios 介绍及封装使用)
  • TortoiseSVN各版本汉化包下载
  • 学习使用Flask模拟接口进行测试
  • 第3章-python深度学习——(波斯美女)
  • angular2开源库收集
  • echarts的各种常用效果展示
  • Elasticsearch 参考指南(升级前重新索引)
  • iOS 颜色设置看我就够了
  • Java多态
  • leetcode讲解--894. All Possible Full Binary Trees
  • mongodb--安装和初步使用教程
  • vue数据传递--我有特殊的实现技巧
  • 程序员该如何有效的找工作?
  • 道格拉斯-普克 抽稀算法 附javascript实现
  • 力扣(LeetCode)357
  • 区块链技术特点之去中心化特性
  • 软件开发学习的5大技巧,你知道吗?
  • 如何通过报表单元格右键控制报表跳转到不同链接地址 ...
  • #WEB前端(HTML属性)
  • (poj1.3.2)1791(构造法模拟)
  • (编译到47%失败)to be deleted
  • (四) Graphivz 颜色选择
  • (转) 深度模型优化性能 调参
  • (转)iOS字体
  • .NET Core实战项目之CMS 第十二章 开发篇-Dapper封装CURD及仓储代码生成器实现
  • .Net 垃圾回收机制原理(二)
  • .net安装_还在用第三方安装.NET?Win10自带.NET3.5安装
  • .pop ----remove 删除
  • @angular/cli项目构建--Dynamic.Form
  • [ vulhub漏洞复现篇 ] ThinkPHP 5.0.23-Rce
  • [100天算法】-x 的平方根(day 61)
  • [100天算法】-实现 strStr()(day 52)
  • [2019.3.5]BZOJ1934 [Shoi2007]Vote 善意的投票
  • [ACTF2020 新生赛]Upload 1
  • [AI]文心一言爆火的同时,ChatGPT带来了这么多的开源项目你了解吗
  • [C++ 从入门到精通] 12.重载运算符、赋值运算符重载、析构函数
  • [C++]unordered系列关联式容器
  • [codevs 1296] 营业额统计
  • [ComfyUI进阶教程] animatediff视频提示词书写要点
  • [flink总结]什么是flink背压 ,有什么危害? 如何解决flink背压?flink如何保证端到端一致性?
  • [GXYCTF2019]BabyUpload1 -- 题目分析与详解
  • [GXYCTF2019]禁止套娃
  • [IE技巧] 如何关闭Windows Server版IE的安全限制
  • [iOS]Win8下iTunes无法连接iPhone版本的解决方法