查看Flink作业详情
创建作业后,您可以在DLI管理控制台查看Flink作业的基本信息、作业详情、任务列表、执行计划等信息。
本节操作介绍怎样查看Flink作业相关信息。
类型 |
说明 |
操作指导 |
---|---|---|
Flink作业基本信息 |
包括Flink作业的ID、作业类型、作业执行状态等信息。 |
|
Flink作业详情 |
包括作业的SQL语句和参数设置信息,Jar作业支持查看参数设置信息。 |
|
Flink作业监控 |
通过云监控服务(CES)查看作业数据输入输出的详细信息。 |
|
Flink作业任务列表 |
查看作业运行时每个任务的详细信息,例如任务的开始时间、收发字节数和运行时长等。 |
|
Flink作业执行计划 |
了解运行中的作业的算子流向。 |
查看Flink作业基本信息
单击“作业管理 > Flink作业”,进入Flink作业管理页面。Flink作业管理页面显示所有的Flink作业,通过Flink作业列表可以了解Flink作业的基本信息。
参数 |
参数说明 |
---|---|
ID |
所提交Flink作业的ID,由系统默认生成。 |
名称 |
所提交Flink作业的名称。 |
类型 |
所提交Flink作业的类型。包括:
|
状态 |
作业的状态信息。具体状态信息以控制台为准。 |
描述 |
所提交Flink作业的描述。 |
用户名 |
提交作业的用户名称。 |
创建时间 |
每个作业的创建时间。 |
开始时间 |
Flink作业开始运行的时间。 |
运行时长 |
作业运行所消耗的时间。 |
操作 |
|
查看Flink作业详情
用户作业创建完成并保存后,用户可以单击作业名查看作业的详细信息,包括作业的SQL语句和参数设置信息,如果是 jar作业只可以看到参数设置信息。
- 在DLI管理控制台的左侧导航栏中,单击 > ,进入Flink作业管理页面。
- 单击需要查看的作业名称,进入“作业详情”页面。
在“作业详情”页签,您可以查看作业的SQL语句、作业配置信息、任务列表、执行计划、提交日志、运行日志、日志列表、标签。
查看Flink作业监控
用户可以通过云监控服务(CES)查看作业数据输入输出的详细信息。
- 在DLI管理控制台的左侧导航栏中,单击 > ,进入Flink作业管理页面。
- 单击需要查看的作业名称,进入“作业详情”页面。
单击页面右上角的“作业监控”,将跳转至云监控服务(CES)。图1 作业监控
Flink 作业包含如下监控指标。
表3 Flink作业监控指标 指标名称
说明
Flink作业数据输入速率
展示用户Flink作业的数据输入速率,供监控和调试使用。单位:条/秒。
Flink作业数据输出速率
展示用户Flink作业的数据输出速率,供监控和调试使用。单位:条/秒。
Flink作业数据输入总数
展示用户Flink作业的数据输入总数,供监控和调试使用。单位:条。
Flink作业数据输出总数
展示用户Flink作业的数据输出总数,供监控和调试使用。单位:条。
Flink作业字节输入速率
展示用户Flink作业每秒输入的字节数。单位:字节/秒。
Flink作业字节输出速率
展示用户Flink作业每秒输出的字节数。单位:字节/秒。
Flink作业字节输入总数
展示用户Flink作业字节的输入总数。单位:字节。
Flink作业字节输出总数
展示用户Flink作业字节的输出总数。单位:字节。
Flink作业CPU使用率
展示用户Flink作业的CPU使用率。单位:%。
Flink作业内存使用率
展示用户Flink作业的内存使用率。单位:%。
Flink作业最大算子延迟
展示用户Flink作业的最大算子延迟时间,单位ms。
Flink作业最大算子反压
展示用户Flink作业的最大算子反压值,数值越大,反压越严重。
0:表示OK
50:表示Low
100:表示High
查看Flink作业任务列表
用户可以查看作业运行时每个任务的详细信息,例如任务的开始时间、收发字节数和运行时长等。

如果数据为零,表示没有从数据源接收到数据。
- 在DLI管理控制台的左侧导航栏中,单击 > ,进入Flink作业管理页面。
- 单击需要查看的作业名称,进入“作业详情”页面。
- 在“任务列表”页签,可以查看任务的节点信息。
图2 任务列表查看算子任务列表,具体参见下表:
表4 算子任务列表参数 参数
说明
名称
算子名称。
持续时间
算子运行的持续时间。
最大并行数
算子中并行的Task的个数。
任务
算子的任务有以下几种:
- 红色数字表示已失败的Task个数。
- 浅灰色数字表示已取消的Task个数。
- 黄色数字表示取消中的Task个数。
- 绿色数字表示已完成的Task个数。
- 蓝色数字表示运行中的Task个数。
- 天蓝色数字表示部署中的Task个数。
- 深灰色数字表示排队中的Task个数。
状态
算子任务对应的状态。
反压状态
算子的工作负荷状态。包含如下几种状态:
- OK:表示工作负荷正常。
- LOW:表示工作负荷略高。DLI处理数据的速度比较快。
- HIGH:表示工作负荷高。源端输入数据的速度比较慢。
时延
指事件从源端算子到达本算子的过程中消耗的时间,单位为毫秒(ms)。
发送的记录数
算子发送数据的记录。
发送的字节数
算子发送的字节数。
接受的字节数
算子接收的字节数。
接受的记录数
算子收到数据的记录。
开始时间
算子运行开始时间。
结束时间
算子运行结束时间。