[
https://issues.apache.org/jira/browse/FLINK-14992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16986593#comment-16986593
]
Jeff Zhang commented on FLINK-14992:
------------------------------------
Here's what I did in my repo.
https://github.com/zjffdu/flink/commit/ce07c691c7c4f15ba93b91f85a5c2a3c86dc2c2c
It might be fine to just add method to allow add listener in Environment and
call them in the old code path and delegate it to Executor in future since this
is implementation details which is not exposed to users.
> Add job submission listener to execution environments
> -----------------------------------------------------
>
> Key: FLINK-14992
> URL: https://issues.apache.org/jira/browse/FLINK-14992
> Project: Flink
> Issue Type: Sub-task
> Components: API / DataSet, API / DataStream
> Reporter: Aljoscha Krettek
> Priority: Major
> Fix For: 1.10.0
>
>
> 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
> {code}
> interface JobSubmissionListener {
> void notify(JobClient jobClient)
> }
> {code}
> with a method {{registerJobSubmissionListener(JobSubmissionListener)}} on the
> environments.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
