[
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 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.)
> 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)
