[FLINK-33212] Introduce job status changed listener for lineage

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Affects Version/s: 1.20.0
• Component/s: Runtime / REST
• Labels: pull-request-available
• Assignee: Zhenqiu Huang
• Reporter: Fang Yong
• Created: 09/Oct/23 05:22
• Updated: 03/Jul/24 02:37
• Resolved: 03/Jul/24 02:37

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.

Issue Links

• links to: GitHub Pull Request #24754