[ 
https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Zhenqiu Huang closed FLINK-33212.
---------------------------------
    Resolution: Done

The PR is merged to upstream.

> Introduce job status changed listener for lineage
> -------------------------------------------------
>
>                 Key: FLINK-33212
>                 URL: https://issues.apache.org/jira/browse/FLINK-33212
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / REST
>    Affects Versions: 1.20.0
>            Reporter: Fang Yong
>            Assignee: Zhenqiu Huang
>            Priority: Major
>              Labels: pull-request-available
>
> Introduce job status changed listener relevant interfaces and its 
> implementation. The job listeners will be registered in runtime and also 
> client side pipeline executors, including localExecutor, embeddedExecutor for 
> application mode, and  abstract session cluster executor.  When job 
> submission is successfully, the job created event will be created with 
> lineage graph info.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to