getOrcaCheckpointSubjobInfo
语法
getOrcaCheckpointSubjobInfo([name])
参数
name 可选参数,字符串标量,表示流图的名字。可以传入完整的流图全限定名(如 catalog_name.orca_graph.graph_name),也可以仅提供流图名(如 factors);系统会根据当前的 catalog 设置自动补全为对应的全限定名。
详情
查看指定流图 Checkpoint 子任务的运行情况。如果未指定 name,则返回 Orca 中所有流图的 Checkpoint 运行情况。
返回一个表,包括以下字段:
checkpointId:Checkpoint id
jobId:流图 id
subjobId:子任务 id
firstBarrierArrTs:Checkpoint 子任务收到第一个 Barrier 的时刻。
barrierAlignTs:Checkpoint 子任务的 Barrier 对齐的时刻。
barrierForwardTs:Checkpoint 子任务向下游转发 Barrier 的时刻。
status:Checkpoint 子任务状态,包括 running、success、failed。
snapshotChannelsId:Checkpoint 子任务的输入端 Channel 的 id。
downstreamSubscribeOffsets:下游订阅的 offset。
snapshotMeta:Checkpoint 数据的元信息。
extra:额外信息,例如 Checkpoint 的错误信息
例子
getOrcaCheckpointSubjobInfo("streamGraph1") // name 是流图名称
getOrcaCheckpointSubjobInfo("catalog1.orca_graph.streamGraph1") // name 是全限定名