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

Reply via email to