Return-Path: <user-return-14211-archive-asf-public=cust-asf.ponee.io@flink.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 5B9FB200CCB
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Thu, 20 Jul 2017 18:56:12 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id 59E0F16BAD1; Thu, 20 Jul 2017 16:56:12 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 8FFD216BACE
	for <archive-asf-public@cust-asf.ponee.io>; Thu, 20 Jul 2017 18:56:11 +0200 (CEST)
Received: (qmail 87772 invoked by uid 500); 20 Jul 2017 16:56:10 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 87762 invoked by uid 99); 20 Jul 2017 16:56:10 -0000
Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Jul 2017 16:56:10 +0000
Received: from aljoschas-mbp.fritz.box (ipservice-092-208-199-000.092.208.pools.vodafone-ip.de [92.208.199.0])
	by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id C85A31A0029;
	Thu, 20 Jul 2017 16:56:09 +0000 (UTC)
Content-Type: text/plain; charset=us-ascii
Mime-Version: 1.0 (Mac OS X Mail 10.3 \(3273\))
Subject: Re: Detached execution API
From: Aljoscha Krettek <aljoscha@apache.org>
In-Reply-To: <1500565899957-14366.post@n4.nabble.com>
Date: Thu, 20 Jul 2017 18:56:08 +0200
Cc: user@flink.apache.org
Content-Transfer-Encoding: quoted-printable
Message-Id: <7BBBDF6F-5C51-4AC7-8D09-A9E34FCC8F43@apache.org>
References: <1500565899957-14366.post@n4.nabble.com>
To: nragon <nuno.goncalves@wedotechnologies.com>
X-Mailer: Apple Mail (2.3273)
archived-at: Thu, 20 Jul 2017 16:56:12 -0000

Hi,

I think you might find those two issues interesting:

- https://issues.apache.org/jira/browse/FLINK-2313: Change Streaming =
Driver Execution Model
- https://issues.apache.org/jira/browse/FLINK-4272: Create a JobClient =
for job control and monitoring

Best,
Aljoscha

> On 20. Jul 2017, at 17:51, nragon =
<nuno.goncalves@wedotechnologies.com> wrote:
>=20
> It would be nice to let users deploy detached jobs through api.
> For instance>
>=20
> *StreamExecutionEnviroment*
>=20
>  public JobExecutionResult execute() throws Exception {
>    return execute(DEFAULT_JOB_NAME, false);
>  }
> Which keep backward compatibility
>=20
>  public abstract JobExecutionResult execute(String jobName, boolean
> detached) throws Exception;
>=20
> *RemoteStreamEnvironment*
>=20
> @Override
>  public JobExecutionResult execute(String jobName, boolean detached) =
throws
> ProgramInvocationException {
>    StreamGraph streamGraph =3D getStreamGraph();
>    streamGraph.setJobName(jobName);
>    transformations.clear();
>    return executeRemotely(streamGraph, jarFiles, detached);
>  }
>=20
> ---------------------
>=20
> protected JobExecutionResult executeRemotely(StreamGraph streamGraph,
> List<URL> jarFiles, boolean detached) throws =
ProgramInvocationException {
> .....
> ClusterClient client;
>    try {
>      client =3D new StandaloneClusterClient(configuration);
>      client.setDetached(detached);
>=20
> =
client.setPrintStatusDuringExecution(getConfig().isSysoutLoggingEnabled())=
;
>    }
> ....
> }
>=20
> Just an idea. I'm using the previous approach and it works fine.
>=20
> Thanks
>=20
>=20
>=20
> --
> View this message in context: =
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Detach=
ed-execution-API-tp14366.html
> Sent from the Apache Flink User Mailing List archive. mailing list =
archive at Nabble.com.