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.d...@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 >
