[FLINK-14992] Add job submission listener to execution environments

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: API / DataSet, API / DataStream
• Labels: pull-request-available
• Assignee: Jeff Zhang
• Reporter: Aljoscha Krettek
• Created: 29/Nov/19 14:28
• Updated: 10/Dec/19 08:56
• Resolved: 10/Dec/19 08:06

Description

We should add a way of registering listeners that are notified when a job is submitted for execution using an environment. This is useful for cases where a framework, for example the Zeppelin Notebook, creates an environment for the user, the user can submit jobs, but the framework needs a handle to the job in order to manage it.

This can be as simple as

interface JobSubmissionListener {
    void notify(JobClient jobClient)
}

with a method registerJobSubmissionListener(JobSubmissionListener) on the environments.

Issue Links

• relates to: FLINK-15116 Make JobClient stateless, remove AutoCloseable
• links to: GitHub Pull Request #10408
• links to: GitHub Pull Request #10479
• links to: GitHub Pull Request #10497