本文为您介绍如何查看作业的详情和状态,以及如何修改作业状态和配置信息。
查看作业详情
- 登录实时计算统一控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击作业列表。
- 单击目标作业名称。
- 在作业详情页面,查看以下信息。
- 作业总览:作业参数总览。说明 单击指标,您可以查看更多指标,包括Flink的常用指标。
- 数据曲线:展示Flink的常用指标。
Flink全托管VVR 2.1.3及以上版本支持的Metrics指标如下表所示:
说明 “√”表示上报Metrics,“x”表示暂未支持上报Metrics。- Source
Connector numBytesIn numBytesInPerSecond numRecordsIn numRecordsInPerSecond numRecordsInErrors currentFetchEventTimeLag currentEmitEventTimeLag watermarkLag sourceIdleTime pendingBytes pendingRecords Kafka √ √ √ √ x √ √ √ √ x √ MaxCompute √ √ √ √ x x x x x x x 增量MaxCompute √ √ √ √ x x x x x x x MQ √ √ √ √ √ √ √ √ √ x x SLS x x √ √ x √ √ √ x x x DataHub x x √ √ x √ √ √ x x x ElasticSearch x x √ √ x x x x x x √ Hologres x x √ √ x x x x x x x 云数据库HBase x x x x x x x x x x x Tablestore x x x x x x x x x x x Phoenix x x x x x x x x x x x Redis x x x x x x x x x x x - Sink
Connector numBytesOut numBytesOutPerSecond numRecordsOut numRecordsOutPerSecond numRecordsOutErrors currentSendTime Kafka √ √ √ √ √ √ MaxCompute x x x √ x √ 增量MaxCompute x x x √ x √ MQ √ √ x x x √ SLS x x √ √ x √ DataHub √ √ √ √ x √ ElasticSearch x x x x x x Hologres x x √ √ x √ 云数据库HBase √ √ √ √ x √ Tablestore x x √ √ x √ Phoenix x x √ √ x √ Redis x x √ √ x √
- Source
- 运行事件:作业运行中的事件。运行事件页面上,默认展示消息发生的时间、信息和操作三部分信息,其中具体操作包括以下操作:
- 复制信息:复制信息内容。
- 实例详情:查看作业产生事件的详细信息,包括实例信息、Artifact配置、Flink配置、日志配置和Logging Level配置等。
说明
- 在作业总览页面右上角,单击Flink UI,可以跳转到运行作业的开源Flink UI界面。
- 单击指标,可以跳转到运行作业的VVP(Ververica Platform)的指标界面。指标界面默认展示的是从事件发生时间起30分钟内的指标信息。
- 搜索该实例事件:过滤出该实例的事件。
- 作业总览:作业参数总览。
查看作业状态
- 登录实时计算统一控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击作业列表。
- 单击目标作业名称。
- 在作业总览页签,查看作业状态信息。页面左上角会显示两种作业状态:
- 期望状态
状态 说明 RUNNING 按作业配置定义,启动作业。 CANCELLED 停止任何正在运行的作业。 SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。 - 当前状态
状态 说明 RUNNING 按作业配置定义,启动作业。 CANCELLED 停止任何正在运行的作业。 SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。 FINISHED 作业运行完成。 TRANSITIONING 作业处于向期望状态的过度阶段。 FAILED 作业向期望状态转换失败,需要手动处理。 ClusterUnreachable VVP无法访问JM(JobManager)获取不到Job的状态。
说明 单击启动后,作业的期望状态会立刻变成RUNNING,当前状态会变成TRANSITIONING,并显示作业启动进度。前端开发平台VVP(Ververica Platform)会保证Flink作业最终达到期望状态。如果Flink作业状态正在从某个状态变成期望状态的过程中,而作业的最终期望状态发生了改变,作业会先到达最初的期望状态,再转换为最终的期望状态。
- 期望状态
修改作业状态
- 登录实时计算统一控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击作业列表。
- 单击目标作业名称。
- 单击总览页签,进入作业详情页面。
- 根据需要单击以下按钮,修改作业状态。其中,每个按钮含义如下表所示。
操作名称 说明 暂停 暂停作业,先对当前运行的作业创建Savepoint,再停止作业。暂停作业需要具备以下两个条件: - Savepoint地址配置完成。如果Savepoint地址没有配置,暂停操作将直接停止作业,导致作业状态丢失。
- Savepoint操作成功。
停止 停止作业。 诊断 系统会根据收集到的瞬时作业信息(例如Failover等)和常见的作业诊断规则,给您一些简单指导意见。 Savepoint 创建一个当前时刻的Savepoint。 说明 请先完成Savepoint地址配置,否则Savepoint会失败。克隆 复制一个作业。 说明- 复制的作业处于CANCELLED状态。
- 复制作业名称为Fork of 原作业名称,例如:Fork of test2。
编辑 修改作业基础配置或高级配置。 删除 删除作业。只能删除当前状态不为RUNNING的作业。
修改作业配置
作业配置包含作业上线阶段所有的配置内容。
- 登录实时计算统一控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击作业列表。
- 单击目标作业名称。
- 修改作业配置信息。您可以通过以下任何一种方式修改作业配置:
- 以模板模式编辑在页面右上角,单击编辑后,修改配置信息。
- 以YAML模式编辑在页面右上角,单击编辑后,单击以YAML模式编辑页签修改配置信息。
- 以模板模式编辑
- 单击保存。
在文档使用中是否遇到以下问题
更多建议
匿名提交