[ https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650974#comment-15650974 ]
ASF GitHub Bot commented on FLINK-4272: --------------------------------------- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2732#discussion_r87050139 --- Diff: flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java --- @@ -207,14 +207,23 @@ public JobExecutionResult executePlanWithJars(JobWithJars program) throws Except shutDownAtEnd = false; } - try { - return client.run(program, defaultParallelism).getJobExecutionResult(); - } - finally { - if (shutDownAtEnd) { - stop(); - } - } + final JobClient jobClient = client.run(program, defaultParallelism); + + jobClient.addFinalizer( + new Runnable() { + @Override + public void run() { + if (shutDownAtEnd) { --- End diff -- Maybe moving this out of the runnable. > Create a JobClient for job control and monitoring > -------------------------------------------------- > > Key: FLINK-4272 > URL: https://issues.apache.org/jira/browse/FLINK-4272 > Project: Flink > Issue Type: New Feature > Components: Client > Reporter: Maximilian Michels > Assignee: Maximilian Michels > Priority: Minor > Fix For: 1.2.0 > > > The aim of this new features is to expose a client to the user which allows > to cancel a running job, retrieve accumulators for a running job, or perform > other actions in the future. Let's call it {{JobClient}} for now (although > this clashes with the existing JobClient class which could be renamed to > JobClientActorUtils instead). > The new client should be returned from the {{ClusterClient}} class upon job > submission. The client should also be instantiatable by the users to retrieve > the JobClient with a JobID. > We should expose the new JobClient to the Java and Scala APIs using a new > method on the {{ExecutionEnvironment}} / {{StreamExecutionEnvironment}} > called {{executeWithControl()}} (perhaps we can find a better name). -- This message was sent by Atlassian JIRA (v6.3.4#6332)