Hi, We are submitting a Flink topology [YARN] and it fails during upload of the jar with no error info.
[main] INFO org.apache.flink.runtime.client.JobClient - Checking and uploading JAR files [main] ERROR org.apache.flink.client.CliFrontend - Error while running the command. org.apache.flink.client.program.ProgramInvocationException: The program execution failed: JobManager did not respond within 60000 ms Flink UI says: “Could not retrieve the redirect address of the current leader. Please try to refresh.” We tried increasing job manager memory to 8GB and still it has the same issue. Jar size is around 190 MB but we were able to successfully run this size before. Zookeeper in Hadoop YARN cluster is healthy. How do we start debugging this? Is it some dependency jar issue in our uber jar or something else? Thanks, -Fakrudeen (define (sqrte n xn eph) (if (> eph (abs (- n (* xn xn)))) xn (sqrte n (/ (+ xn (/ n xn)) 2) eph)))