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

Reply via email to