Hi Elkhan,
I confirm that the FlinkSQL Client is communicating with JM via Rest endpoint.
After I changed the “rest.port”, the sql client thrown exception: "[ERROR]
Could not execute SQL statement. Reason:
java.net.ConnectException: Connection refused”.
So for your case, since Flink will creat
Hi Elkhan,
Except for JM have an external IP address, I think the port 6123 also need to
be opened. You may need to set a host port for 6123 in JM pod or expose this
port by Kubernetes service.
But I am not sure whether the sql-client communicate with JM via Rest endpoint
or RPC port. Hopes som
Hi Flink users,
Wanted to check if any of you tried to run the local FlinkSQL client
against JobManager running in the Kubernetes environment.
For local FlinkSQL Client and local Flink cluster we set these params:
jobmanager.rpc.address: localhost
jobmanager.rpc.port: 6123
To make it work, Is t
