[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210842#comment-17210842
]
Matthias commented on FLINK-12214:
----------------------------------
The [mailing list
discussion|http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Discuss-Add-JobListener-hook-in-flink-job-lifecycle-td27370.html]
idled for quite some time. I revived it to see whether there is still some
support for proceeding here.
> Add JobListener(hook) in flink job lifecycle
> --------------------------------------------
>
> Key: FLINK-12214
> URL: https://issues.apache.org/jira/browse/FLINK-12214
> Project: Flink
> Issue Type: New Feature
> Components: Runtime / Coordination
> Reporter: Jeff Zhang
> Assignee: Jeff Zhang
> Priority: Major
> Labels: pull-request-available
> Attachments: image-2019-04-17-00-11-00-020.png,
> image-2019-04-17-00-13-15-999.png, image-2019-04-17-00-15-16-750.png
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> Third party library would like to add some hook when submitting jobs. So it
> would be nice to have JobListener for flink.
> More details about the motivation:
> The background is that I am working on integrating flink with apache zeppelin
> notebook. In apache zeppelin notebook, we allow user to run flink scala code
> or sql. For each piece fo code, I'd like to associate it with its
> corresponding flink job. So that user can link to flink job ui in zeppelin
> notebook, also he can cancel this job. Here's one screenshot of my POC, in
> this screenshot you can see the FLINK JOB link which will link to the flink
> job ui. That's why I'd like to add hook in flink's job submission, so that I
> can link each piece of flink code to paragraph (the following screenshot)
> which is a concept of zeppelin and is a container that host this piece of
> code.
> Here's the sample code for reference about how I use JobListener in zeppelin.
> [https://github.com/zjffdu/zeppelin/blob/blink_poc/flink/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala#L251]
> !image-2019-04-17-00-15-16-750.png!
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
