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

Zhenqiu Huang updated FLINK-33212:
----------------------------------
    Description: # 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.  (was: Introduce job status changed listener relevant interfaces)

> 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