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: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to