git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Multiple env.execute() into one Flink batch job


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@xxxxxxxxx> 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