Did you forget to call executionEnvironment.execute() after you define your Flink job?
-- Rong On Mon, Jul 2, 2018 at 1:42 AM eSKa <eska...@gmail.com> wrote: > Hello, We are currently running jobs on Flink 1.4.2. Our usecase is as > follows: > -service get request from customer > - we submit job to flink using YarnClusterClient > Sometimes we have up to 6 jobs at the same time. > > From time to time we got error as below: > The program didn't contain a Flink job. > org.apache.flink.client.program.ProgramMissingJobException: The program > didn't contain a Flink job. > at > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:398) > > From logs we can see that main method from job is returning correct > status, but for some reason later Flink throws that exception anyway. Do > you know what could be a case here and how to prevent it from happening? > ------------------------------ > Sent from the Apache Flink User Mailing List archive. mailing list archive > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/> at > Nabble.com. >
