flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From eSKa <eska...@gmail.com>
Subject The program didn't contain a Flink job
Date Mon, 02 Jul 2018 08:42:25 GMT
Hello,We are currently running jobs on Flink 1.4.2. Our usecase is as
-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/
View raw message