Hi! By "the streaming job stops" do you mean the job ends with CANCELED state instead of FINISHED state? Which kind of job are you running? Is it a select job or an insert job? Insert jobs should run continuously once they're submitted. Could you share your user code if possible?
Yuval Itzchakov <yuva...@gmail.com> 于2021年12月22日周三 14:11写道： > 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 >>> >>
