Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5207#discussion_r161010273 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -148,6 +181,39 @@ private void submitJob(JobGraph jobGraph) throws JobSubmissionException { } } + private JobExecutionResult waitForJobExecutionResult( + final JobID jobId) throws ProgramInvocationException { + + final JobMessageParameters messageParameters = new JobMessageParameters(); + messageParameters.jobPathParameter.resolve(jobId); + JobExecutionResultResponseBody jobExecutionResultResponseBody; + try { + long attempt = 0; + do { + final CompletableFuture<JobExecutionResultResponseBody> responseFuture = + restClient.sendRequest( + restClusterClientConfiguration.getRestServerAddress(), + restClusterClientConfiguration.getRestServerPort(), + JobExecutionResultHeaders.getInstance(), + messageParameters); + jobExecutionResultResponseBody = responseFuture.get(timeout.toMillis(), TimeUnit.MILLISECONDS); + Thread.sleep(waitStrategy.sleepTime(attempt)); + attempt++; + } + while (jobExecutionResultResponseBody.getStatus().getStatusId() != QueueStatus.StatusId.COMPLETED); --- End diff -- Alright, then let's do it there.
---