Flink半托管版本提供Flink全球统一的官方商用开发控制平台Ververica Platform(后面简称VVP)。您可以在VVP完成一站式的作业开发、提交和运维,让Flink的使用更简单高效。

Deployment

Deployment与作业的概念类似,定义了Flink Application的期望状态和相关配置,是VVP的核心组件。
  • 提交Deployment

    参见作业提交流程

  • 状态
    Deployment运行存在一个最终的状态,Deployment的最终状态存在以下几种。
    状态 说明
    Running Flink作业处于运行中。
    Cancelled 用户终止了Flink作业。
    Suspended 先对当前运行的作业创建Savepoint,再停止作业。
    Failed Deployment向期望状态转化失败,需要手动处理。
  • Upgrade Strategy您可以通过设置升级策略,对运行中作业的资源、运行版本或作业运行参数等信息进行修改。
    • Stateless:参数修改完成后,直接重启您的作业应用新配置。
    • Stateful:参数修改完成后,作业将先创建一次Savepoint,再应用新的配置重启作业。
    • None:不会自动重启作业。您需要手动操作,完成新配置的应用。
  • Initial State
    新建的作业的初始状态。
    • Running:作业创建完成后会直接运行。
    • Cancelled:作业创建完成后,需要手动操作进行启动。
  • Restore Strategy
    VVP支持您在选择恢复作业的方式,包括以下两种:
    • Latest Savepoint:使用最后一个通过VVP,创建成功的Savepoint。
    • Latest State:最后一个可用State。
    • None:不带状态恢复,不使用Savepoint。
    说明 Upgrade StrategyRestore Strategy需要配合使用。例如,如果Upgrade Strategy选择STATEFULRestore Strategy选择NONE,则完成Savepoint后,作业会从作业的起始时间重新启动,而不是从Savepoint恢复。
  • Allow Non-Restore Strategy

    开启该功能后,在Savepoint不兼容的情况下,不会报错中断作业,而是重新启动作业。

Setting

VVP相关设置,包含以下四部分:
  • Deployment Targets:选择Deployment在K8s集群运行的Namespace。
    VVP服务启动时会创建一个默认的Deployment Targets和K8s的Namespace关联。Deployment在上线时可以选择Deployment Targets运行在特定的K8s的Namespace下,您也可以创建新的关联信息。
    说明 您填写的K8s的Namespace必须是确定存在的,否则Deployment Targets无效,使用该Deployment Target启动的作业会失败。
  • Members
    针对Namespace的授权策略,仅具有管理员角色的用户可以通过填写其它用户的阿里云UID,来控制不同用户在该Namepsace下的权限。
    说明 请使用user:UID的格式进行添加,否则权限无法生效。
    • owner

      能够查看、编辑和启停作业,以及授予其它用户权限等。

    • editor

      可以对Namespace中作业进行查看、编辑和启停。

    • viewer

      只能查看Namespace下的作业。

  • Secret Values:Namespace级别的全局变量,key-value形式,在作业参数引用的时候使用${key}的形式就可以获取到value的值。
  • API Tokens:对API用户的Tokens进行授权,角色分为OwnerEditorViewer

PlatForm

说明 仅集群的管理员角色可以查看PlatForm界面。
  • Namespace
    该NameSpace仅是VVP的NameSpace,此处新建NameSpace不会出现在K8s上。在VVP上,NameSpace的概念类似于Project,您可以根据业务需求结合授权方式,在不同的Namespace中管理不同的作业。创建Namespace时,需要指定Namespace的NameOwners
    说明 请使用user:UID的格式进行添加,否则权限无法生效。
  • System Info:时区设置和版本信息展示。
    说明 目前时区设置仅决定属性的显示(例如前端作业启动时间等),不会参与Flink作业中的计算。