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用户进行授权。令牌角色分为owner、editor和viewer。注意 创建完令牌后,请立即复制令牌信息并妥善保存,否则刷新该页面后,您将无法查看令牌信息。
- 成员管理您可以为阿里云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作业中的计算。
在文档使用中是否遇到以下问题
更多建议
匿名提交