【flink脚本系列】 historyserver.sh功能用法示例源码解析_flink historyserver.sh

脚本主要功能

该脚本用于启动或停止 Flink 的 HistoryServer，它提供了以下功能：

• 启动 HistoryServer
• 以前台模式启动 HistoryServer
• 停止 HistoryServer

脚本加上中文注释

#!/bin/bash

# Start/stop a Flink HistoryServer
USAGE="使用方法：historyserver.sh (start|start-foreground|stop)"

STARTSTOP=$1  # 获取启动或停止参数

bin=`dirname "$0"`  # 获取脚本所在目录
bin=`cd "$bin"; pwd`  # 转换为绝对路径

. "$bin"/config.sh  # 加载配置文件

if [[ $STARTSTOP == "start" ]] || [[ $STARTSTOP == "start-foreground" ]]; then
    export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_HS}"
    args=("--configDir" "${FLINK_CONF_DIR}")  # 设置启动参数（配置目录）
fi

if [[ $STARTSTOP == "start-foreground" ]]; then
    exec "${FLINK_BIN_DIR}"/flink-console.sh historyserver "${args[@]}"  # 在前台模式下启动 HistoryServer
else
    "${FLINK_BIN_DIR}"/flink-daemon.sh $STARTSTOP historyserver "${args[@]}"  # 启动或停止 HistoryServer
fi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

该脚本多种用法及其代码示例

• 启动 HistoryServer：./historyserver.sh start
• 以前台模式启动 HistoryServer：./historyserver.sh start-foreground
• 停止 HistoryServer：./historyserver.sh stop

Flink中其他类似脚本

在Flink中，还有其他类似的脚本用于启动、停止和管理不同组件，例如：

• start-cluster.sh：启动 Flink 集群
• stop-cluster.sh：停止 Flink 集群
• taskmanager.sh：启动或停止 Flink TaskManager
• jobmanager.sh：启动或停止 Flink JobManager

您可以根据需要使用这些脚本来管理和操作 Flink。

官方链接

官方文档中关于 HistoryServer 的详细信息可以在以下链接找到：

https://ci.apache.org/projects/flink/flink-docs-release-1.14/zh/deployment/historyserver.html