[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819578#comment-16819578
]
Jeff Zhang commented on FLINK-12214:
------------------------------------
[~till.rohrmann] I think this issue is orthogonal with FLINK-4272. FLINK-4272
is to provide fine grained control of job in the process of job submission, but
this ticket is to add hook interface to job submission. Besides, FLINK-4272 can
not meet my requirement. In zeppelin notebook, job submission is via user code
in scala shell which is out of my control. I can not get JobClient. Another
scenario I can think of is that if user submit flink job implicitly via
TableEnviroment api, he also can not get JobClient.
Hope this can clarify my usage scenario and motivation.
> Add JobListener to capture job submission process
> -------------------------------------------------
>
> 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
(v7.6.3#76005)
