【极数系列】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.mzph.cn/news/653761.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

解决Ubuntu20.04远程时必须连接显示器

此文档解决Ubuntu20.04远程使用时必须连接服务器的问题。通过使用虚拟服务器,让设备无显示器也可以远程。只需要新建一个文件,将命令粘贴进去即可。 目录 1)安装软件 2)添加配置文件 3)编辑配置文件 4&#xff09…

verdaccio搭建npm私服

一、安装verdaccio 注:加上–unsafe-perm的原因是防止报grywarn权限的错 npm install -g verdaccio --unsafe-perm 二、启动verdaccio verdaccio 三、配置文件 找到config.yml一般情况下都在用户下的这个文件夹下面 注:首次启动后才会生成 C:\Users\h…

Idea上操作Git回退本地版本,怎么样保留已修改的文件,回退本地版本的四种方式代表什么?

Git的基本概念:Git是一个版本控制系统,用于管理代码的变更历史记录。核心概念包括仓库、分支、提交和合并。 1、可以帮助开发者合并开发的代码 2、如果出现冲突代码的合并,会提示后提交合并代码的开发者,让其解决冲突 3、代码文件版本管理 问题描述 当我们使用git提交代码…

深入了解低代码开发:多角度分类

引言 随着数字化时代的到来,应用程序的需求不断增长,企业和开发者们面临着更多的挑战,包括开发周期的压力、技术复杂性的增加以及对高效协作的需求。在这一背景下,低代码开发应运而生,成为解决这些挑战的一种强大工具…

算法基础课-数据结构

单链表 题目链接:826. 单链表 - AcWing题库 思路:AcWing 826. 单链表---图解 - AcWing 需要注意的点在于理解ne[idx] head,idx表示当前的点,意思是将当前的点链到头结点的后面,再将头结点链在当前idx的前面。 #inc…

JVM系列——垃圾收集器

对象存活判断 引用计数法 在对象中添加一个引用计数器,每当有一个地方引用它时,计数器值就加一;当引用失效时,计数器值就减一;任何时刻计数器为零的对象就是不可能再被使用的。 可达性分析算法 通过一系列称为“GC …

基于springboot+微信小程序+vue实现的校园二手商城项目源码

介绍 校园二手商城,架构:springboot微信小程序vue 软件架构 软件架构说明 系统截图 技术选型 技术版本说明Spring Boot2.1.6MVC核心框架Spring Security oauth22.1.5认证和授权框架MyBatis3.5.0ORM框架MyBatisPlus3.1.0基于mybatis,使用…

Whatsapp相关(四)

Whatsapp相关(四) 书接上文: whatsapp相关(三)-消息发送 1: 编写脚本 首先我们先通过SQLiteDatabase的insert方法.来打印相关的操作. Java.perform(function() {console.log("insert 0: 可以发消息了")var database Java.use(android.database.sqlite.SQLiteDa…

【蓝桥备赛】妮妮的月饼工厂——二分查找

题目链接 妮妮的月饼工厂 个人思路 通过二分查找,寻找满足条件的高度,判定标准是当我们选择mid高度时,我们可以切出的月饼个数是否满足题目要求的 K 个。 static boolean check(long mid) {if (mid 0) return false;long res 0;for (int …

蓝桥杯备战——8.DS1302时钟芯片

1.分析原理图 由上图可以看到,芯片的时钟引脚SCK接到了P17,数据输出输入引脚IO接到P23,复位引脚RST接到P13。 2.查阅DS1302芯片手册 具体细节还需自行翻阅手册,我只截出重点部分 总结:数据在上升沿写出,下降沿读入,…

QGIS使用地理配准将3857坐标系转成上海城建坐标

控制点格式 如 mapX mapY sourceX sourceY enable dX dY residual -58653 70641 13452659.39 3746386.025 1 0 0 0 -58653 65641 13452693.09 3740477.283 1 0 0 0 ......保存为.points格式 图层预处理 图层投影为3857坐标系 地理配准 1. 打开图层-地理配准 工具 2. 导入…

import org.apache.commons.lang3.ObjectUtils;下的ObjectUtils工具类

目录 依赖 1.ObjectUtils.compare() 1.1比较Integer类型数据大小 1.2比较int类型数据大小 2.ObjectUtils.CONST()&#xff1a;作用是将value的值赋给result 1.boolean类型 依赖 <!-- lang3 可以使用其中的工具类来处理字符串、日期、数组等等常见的功能--><depe…

基于FX构建大型Golang应用

Uber开源的FX可以帮助Go应用解耦依赖&#xff0c;实现更好的代码复用。原文: How to build large Golang applications using FX 构建复杂的Go应用程序可能会引入很多耦合 Golang是一种流行编程语言&#xff0c;功能强大&#xff0c;但人们还是会发现在处理依赖关系的同时组织大…

sql注入第一关

判断注入点的类型 通常 Sql 注入漏洞分为 2 种类型&#xff1a; 数字型字符型 数字型测试 在参数后面加上单引号,比如: http://xxx/abc.php?id1 如果页面返回错误&#xff0c;则存在 Sql 注入。 原因是无论字符型还是整型都会因为单引号个数不匹配而报错。 如果未报错&…

Go语言中的HTTP代理处理机制

在当今的互联网世界&#xff0c;HTTP代理是一种常见的网络通信方式&#xff0c;用于保护用户的隐私、突破网络限制或提高网络访问速度。在Go语言中&#xff0c;代理处理机制的实现可以为开发者提供强大的网络通信能力。本文将深入探讨Go语言中的HTTP代理处理机制。 首先&#…

使用Windows API实现屏幕截图及服务器传输

功能描述 屏幕截图在许多应用程序和系统中都是一个有用的功能。有时&#xff0c;我们需要捕获当前屏幕的图像&#xff0c;并将其发送到服务器以供进一步处理或存储。下面的C代码演示了如何使用Windows API以及GDI库来完成这一任务。 关键代码分析 屏幕信息获取&#xff1a; …

render函数的基本实现

在学习vue入门时&#xff0c;一直有一个疑惑如何把虚拟dom转换成真实dom的。 现在猜想&#xff0c;假设虚拟dom长这样&#xff0c;表示要渲染的内容。 const testObj {tag: div,children: [{tag: h1, children: 标题},{tag: h1, children: 标题},{tag: h1, children: 标题},{t…

每日一道面试题:Java中序列化与反序列化

写在开头 哈喽大家好&#xff0c;在高铁上码字的感觉是真不爽啊&#xff0c;小桌板又拥挤&#xff0c;旁边的小朋友也比较的吵闹&#xff0c;影响思绪&#xff0c;但这丝毫不影响咱学习的劲头&#xff01;哈哈哈&#xff0c;在这喧哗的车厢中&#xff0c;思考着这样的一个问题…

【笔记】Helm- 5 Chart模板指南-3 Values文件

Values文件 在上一部分我们了解了Helm模板提供的内置对象。其中一个是Values对象。该对象提供了传递到chart的方法&#xff0c;其内容来自多个位置&#xff1a; 1、chart中的values.yaml文件 2、如果是子chart&#xff0c;就是父chart中的values.yaml文件 3、使用-f参数&…

PrimeFaces修改默认加载动画

Background 默认加载动画不够醒目&#xff0c;我们可以在网上下载个好看的gif图&#xff0c;然后修改默认设置&#xff0c;具体步骤如下参考官方地址&#xff1a;https://www.primefaces.org/showcase/ui/ajax/status.xhtml 实现效果如下 xhtml源码 <p:ajaxStatus onstar…