Hi Elakiya,
In general I think there would be two steps to start a job: launch jm node
including dispatcher, resource manager, and then submit sql job to
dispatcher. The dispatcher will launch a rest server, and the client will
connect to the rest server to submit a job.
>From your error
Hi Shammon,
Thanks for your response.
If it is a network issue as you have mentioned, how does it read the
contents of the jar file, we can see that the code is read and it throws an
error only when executing the SQL. Also can you let us know exactly what
address could be wrong here, so that we
Hi,
It seems that the client can not access the right network to submit you
job, maybe the address option in k8s is wrong and you can check the error
message in k8s log
Best,
Shammon FY
On Fri, Aug 11, 2023 at 11:40 PM elakiya udhayanan
wrote:
>
> Hi Team,
> We are using Apache Flink 1.16.1
Hi Team,
We are using Apache Flink 1.16.1 configured as a standalone Kubernetes pod
,for one of our applications to read from confluent Kafka topics to do
event correlation. We are using the flink's Table API join for the same (in
SQL format).We are able to submit the job using the flink's UI. For
