I mean it finishes successful and exists with status code 0. Both when running locally and submitting to the cluster.
On Wed, Dec 22, 2021, 08:36 Caizhi Weng <tsreape...@gmail.com> wrote: > 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 >>>> >>>
