当前位置: 首页 > 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
http://www.lryc.cn/news/289728.html

相关文章:

  • 2023年深圳市节假日人口迁入数据,shp/excel格式,需要自取!
  • Windows10上通过MSYS2编译FFmpeg 6.1.1源码操作步骤
  • HiveSQL题——用户连续登陆
  • 题解仅供学习使用
  • Linux命令-apt-get命令(Debian Linux发行版中的APT软件包管理工具)
  • matlab appdesigner系列-仪器仪表3-旋钮
  • 常见の算法5
  • MYSQL中group by分组查询的用法详解(where和having的区别)!
  • 架构篇25:高可用存储架构-双机架构
  • 微信小程序(十五)自定义导航栏
  • Python3进行pdf文件分割及转word
  • 深入理解TCP网络协议(1)
  • QT 中如何使用 JSON 功能?
  • C++面试:算法的执行效率和资源消耗、时间和空间复杂度分析根据实际场景,选用合适的数据结构和算法进行程序设计
  • 力扣100215-按键变更的次数
  • STM32-GPIO输出(HAL库)
  • 倒计时80天
  • PBM模型参数详解
  • 贪吃蛇/链表实现(C/C++)
  • Qlik Sense : IntervalMatch(离散匹配)
  • MySql45讲-08.事务到底是隔离的还是不隔离的?(结合MVCC视频)
  • 备战蓝桥杯----数据结构及STL应用(基础2)
  • 日常学习之:vue + django + docker + heroku 对后端项目 / 前后端整体项目进行部署
  • LangGraph:一个基于LangChain构建的AI库,用于创建具有状态、多参与者的应用程序
  • 04-Nacos-服务注册基于spring boot实现
  • iOS 闭包和Block的区别
  • 后端学习笔记——后端细碎知识点(每天更新......)
  • 二进制中1的个数
  • python+matlab text(按图的相对位置显示)
  • rust 引用/mut 的所有权