当前位置:   article > 正文

【flink脚本系列】 kubernetes-jobmanager.sh功能用法示例源码解析

kubernetes-jobmanager.sh

脚本主要功能

该脚本用于在 Kubernetes 上启动 Flink 的 JobManager,它适用于 Flink 的原生 Kubernetes 集成。

注意:此脚本不应手动启动,而是由 Kubernetes 集成使用。

脚本加上中文注释

#!/bin/bash

# Start a Flink JobManager for native Kubernetes.
# NOTE: This script is not meant to be started manually. It will be used by native Kubernetes integration.

USAGE="使用方法:kubernetes-jobmanager.sh kubernetes-session|kubernetes-application [args]"

ENTRY_POINT_NAME=$1  # 获取入口点名称(kubernetes-session或kubernetes-application)
ARGS=("${@:2}")  # 获取参数列表

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

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

# 添加JobManager特定的JVM选项
export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_JM}"
parseJmArgsAndExportLogs "${ARGS[@]}"

if [ ! -z "${DYNAMIC_PARAMETERS}" ]; then
    ARGS=(${DYNAMIC_PARAMETERS[@]} "${ARGS[@]}")
fi

exec "${FLINK_BIN_DIR}"/flink-console.sh ${ENTRY_POINT_NAME} "${ARGS[@]}"
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

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

  • 启动 Kubernetes Session 模式的 JobManager:./kubernetes-jobmanager.sh kubernetes-session
  • 启动 Kubernetes Application 模式的 JobManager:./kubernetes-jobmanager.sh kubernetes-application

Flink中其他类似脚本

在 Flink 中,还有其他类似的脚本用于启动和管理不同组件,例如:

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

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

官方链接

官方文档中关于 Flink 在 Kubernetes 上的原生集成的详细信息可以在以下链接找到:

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

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/714901
推荐阅读
相关标签
  

闽ICP备14008679号