Hi Caizhi, If I don't block on statementset.execute, the job finishes immediately with exit code 0 and the streaming job stops, and that's not what I want. I somehow need to block.
On Wed, Dec 22, 2021, 03:43 Caizhi Weng <tsreape...@gmail.com> wrote: > Hi! > > You can poll the status of that job with REST API [1]. You can tell that > the job successfully finishes by the FINISHED state and that the job fails > by the FAILED state. > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid > > Yuval Itzchakov <yuva...@gmail.com> 于2021年12月22日周三 02:36写道： > >> Hi, >> >> Flink 1.14.2 >> Scala 2.12 >> >> I have a streaming job that executes and I want to infinitely wait for >> it's completion, or if an exception is thrown during initialization. When >> using *statementSet.execute().await()*, I get an error: >> >> Caused by: org.apache.flink.util.FlinkRuntimeException:* The Job Result >> cannot be fetched through the Job Client when in Web Submission.* >> at >> org.apache.flink.client.deployment.application.WebSubmissionJobClient.getJobExecutionResult(WebSubmissionJobClient.java:88) >> at >> org.apache.flink.table.api.internal.InsertResultIterator.hasNext(InsertResultIterator.java:54) >> ... 7 more >> >> This is because the Web Submission via the REST API is using >> the WebSubmissionJobClient. >> >> How can I wait on my Flink SQL streaming job when submitting through the >> REST API? >> -- >> Best Regards, >> Yuval Itzchakov >> >
