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