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

flink安装与配置-脚本一键安装（超简单）

news 来源：原创 2024/5/17 10:20:27

文章目录

前言
使用shell脚本一键安装
- 1. 复制脚本
- 2. 增加执行权限
- 3. 执行脚本
- 4. 加载用户环境变量
- 5. 浏览器访问
总结

前言

本文介绍了使用shell脚本一键安装和配置Apache Flink单机版的方法。通过复制并执行提供的安装脚本，可以自动下载、安装和配置Flink。脚本会检查系统环境和依赖，并进行相应的安装和配置操作。安装完成后，可以通过浏览器访问Flink的用户界面。

使用shell脚本一键安装

1. 复制脚本

首先，将以下脚本内容复制并保存为/tmp/install_flink.sh文件。

#!/bin/bashinstallDir="/opt/module/flink"
flink_version="1.9.2"
scala_version="2.11"if [ -z $(command -v wget) ]; thensudo yum install -y wgetecho "wget安装完成"
fi
if [ -z "$JAVA_HOME" ]; thenecho "JAVA_HOME未设置，请安装jdk1.8，设置Java环境变量再来执行此脚本"exit 1
fi
if [ ! -d "${installDir}" ]; thensudo mkdir -p "${installDir}"if [ $? -eq 0 ]; thenecho "安装目录${installDir}已创建"elseecho "请确保您有足够的权限来创建目录，请增加权限后再次执行"exit 1fi
fi
if [ ! -f /tmp/flink-$flink_version-bin-scala_$scala_version.tgz ]; thenwget https://archive.apache.org/dist/flink/flink-$flink_version/flink-$flink_version-bin-scala_$scala_version.tgz -P /tmpif [ $? -eq 0 ]; thenecho "/tmp/flink-$flink_version-bin-scala_$scala_version.tgz下载成功"elseecho "/tmp/flink-$flink_version-bin-scala_$scala_version.tgz下载失败，请重试或手动下载到/tmp目录下再次执行"echo "下载地址：https://archive.apache.org/dist/flink/flink-$flink_version/flink-$flink_version-bin-scala_$scala_version.tgz"exit 1fi
fiif [ -d $installDir/flink-$flink_version ]; thenecho "$installDir/flink-$flink_version 已存在，正在删除..."sudo rm -rf $installDir/flink-$flink_version
fi
tar -zxvf /tmp/flink-$flink_version-bin-scala_$scala_version.tgz -C $installDir
if [ $? -eq 0 ]; thenecho "/tmp/flink-$flink_version-bin-scala_$scala_version.tgz解压成功"
elseecho "/tmp/flink-$flink_version-bin-scala_$scala_version.tgz解压失败，请查看异常信息后重试"exit 1
fised -i "s|^jobmanager.rpc.address:.*|jobmanager.rpc.address: $(hostname)|" "$installDir/flink-$flink_version/conf/flink-conf.yaml"
# 设置flink用户环境变量
echo >> ~/.bashrc
echo '#FLINK_HOME' >> ~/.bashrc
echo "export FLINK_HOME=$installDir/flink-$flink_version" >> ~/.bashrc
echo 'export PATH=$PATH:$FLINK_HOME/bin' >> ~/.bashrcif [[ $($installDir/flink-$flink_version/bin/flink --version | awk '{ print $1 }') == 'Version:' ]]; thenecho "flink下载、安装、配置完成"
elseecho "安装出现异常，请查看异常信息后重试"exit 1
fi
$installDir/flink-$flink_version/bin/start-cluster.sh
if [ $? -eq 0 ]; thenecho "flink启动成功"ip_addr=$(ip addr | grep 'inet ' | awk '{print $2}'| tail -n 1 | grep -oP '\d+\.\d+\.\d+\.\d+')echo "浏览器访问flink的UI界面：http://$ip_addr:8081/"
elseecho "flink启动失败，请查看异常信息解决后再次尝试启动"exit 1
fiexit 0