flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Multiple env.execute() into one Flink batch job
Date Fri, 23 Nov 2018 15:37:32 GMT
The problem is that the REST API block on env.execute.
If you want to run your Flink job you have to submit it using the CLI
client.
As a workaround we wrote a Spring REST API that to run a job open an SSH
connection to the job manager and execute the bin/flink run command..

If you're interested in I can share some code..



On Fri, Nov 23, 2018 at 4:32 PM bastien dine <bastien.dine@gmail.com> wrote:

> Hello,
>
> I need to chain processing in DataSet API, so I am launching severals
> jobs, with multiple env.execute() :
>
> topology1.define();
> env.execute;
>
> topogy2.define();
> env.execute;
>
> This is working fine when I am running it within IntellIiJ
> But when I am deploying it into my cluster, it only launch the first
> topology..
>
> Could you please shed some light on this issue?
>
> Regards,
> Bastien
>

Mime
View raw message