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 Strategy和Restore Strategy需要配合使用。例如，如果Upgrade Strategy选择STATEFUL，Restore 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进行授权，角色分为Owner、Editor和Viewer。

PlatForm

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