Re: 回复： Flink DataStream 作业如何获取到作业血缘？

Fri, 08 Mar 2024 00:21:21 -0800 

JobGraph 里有个字段就是 jobid。

Best,
Zhanghao Chen
________________________________
From: 阿华田 <a15733178...@163.com>
Sent: Friday, March 8, 2024 14:14
To: user-zh@flink.apache.org <user-zh@flink.apache.org>
Subject: 回复： Flink DataStream 作业如何获取到作业血缘？

获取到Source 或者 DorisSink信息之后, 如何知道来自那个flink任务，好像不能获取到flinkJobId


| |
阿华田
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制


在2024年02月26日 20:04，Feng Jin<jinfeng1...@gmail.com> 写道：
通过 JobGraph 可以获得 transformation 信息，可以获得具体的 Source 或者 Doris
Sink，之后再通过反射获取里面的 properties 信息进行提取。

可以参考 OpenLineage[1] 的实现.


1.
https://github.com/OpenLineage/OpenLineage/blob/main/integration/flink/shared/src/main/java/io/openlineage/flink/visitor/wrapper/FlinkKafkaConsumerWrapper.java


Best,
Feng


On Mon, Feb 26, 2024 at 6:20 PM casel.chen <casel_c...@126.com> wrote:

一个Flink DataStream 作业从mysql cdc消费处理后写入apache
doris，请问有没有办法(从JobGraph/StreamGraph)获取到source/sink
connector信息，包括连接字符串、数据库名、表名等?

回复