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

作业管理

  • JAR包管理

    您可以单击单击可添加文件或将JAR包拖到列表的方式上传JAR包。此外,您还可以下载删除已上传的JAR包。

  • 开发作业

    详情请参见开发

  • 提交作业

    详情请参见提交

  • 作业状态
    页面右上角会显示两种作业状态:
    • 期望状态
      状态 说明
      RUNNING 按作业配置定义,启动作业。
      CANCELLED 停止任何正在运行的作业。
      SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。
    • 当前状态
      状态 说明
      RUNNING 按作业配置定义,启动作业。
      CANCELLED 停止任何正在运行的作业。
      SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。
      FINISHED 作业运行完成。
      TRANSITIONING 作业处于向期望状态的过度阶段。
      FAILED 作业向期望状态转换失败,需要手动处理。
  • 升级策略
    您可以通过设置升级策略,修改运行中作业的资源、运行版本或作业运行参数等信息。升级策略
    • Stateless:参数修改完成后,直接重启您的作业应用新配置。
    • Stateful:参数修改完成后,作业将先创建一次Savepoint,再应用新的配置重启作业。
    • None:不会自动重启作业。您需要手动操作,完成新配置的应用。
  • 恢复策略
    VVP支持您选择恢复作业的策略,包括以下三种:
    • Latest Savepoint:使用最后一个通过VVP,创建成功的Savepoint。
    • Latest State:最后一个可用State。
    • None:不带状态恢复,不使用Savepoint。
    说明 升级策略恢复策略需要配合使用。例如,如果升级策略选择STATEFUL恢复策略选择NONE,则完成Savepoint后,作业会从作业的起始时间重新启动,而不是从Savepoint恢复。
  • Allow Non-Restore Strategy

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

系统管理

  • 作业模板

    您可以通过配置作业模板的方式,配置工作空间下所有作业日志默认输出到OSS或SLS。配置作业模板后,后续该工作空间下创建的所有作业的日志都会被存储到OSS或您配置的SLS项目下的Logstore。

  • 部署目标
    选择作业在K8s集群运行的项目空间。VVP服务启动时会创建一个默认的部署目标和K8s命名空间关联。作业在上线时可以选择部署目标运行在特定的K8s的命名空间下,您也可以创建新的关联信息。
    说明 请确认您填写的K8s的命名空间已存在,否则部署目标无效,使用该部署目标启动的作业会失败。
  • API令牌
    您可以创建令牌,对API用户进行授权。令牌角色分为ownereditorviewer
    注意 创建完令牌后,请立即复制令牌信息并妥善保存,否则刷新该页面后,您将无法查看令牌信息。
  • 成员管理
    您可以为阿里云RAM账号授权:
    • 角色
      不同角色功能差异如下。
      功能 owner editor viewer
      查看作业列表 Y Y Y
      启停作业 Y Y N
      更改作业配置 Y Y N
      上传JAR Y Y N
      查看作业模板 Y Y Y
      增删改作业模板 Y Y N
      管理成员 Y N N
    • 成员
      固定格式为user:UID。其中:
      • user:固定值,不可修改。
      • UID:阿里云RAM账号。
        注意 英文冒号(:)和UID之间不能有空格,否则授权无效。

系统信息

您可以在系统信息页面,设置平台语言用户界面时区。此外,您还可以查看版本信息License信息
说明 目前时区设置仅决定属性的显示(例如作业启动时间等),不会参与Flink作业中的计算。