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 >
