Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-06-02 Thread Ammu P
Hi Shengkai, Thanks for assigning the issue. I have a PR[1] raised for the same which is awaiting review. Could you please have a look. Many Thanks. [1] https://github.com/apache/flink/pull/26378 Regards, Ammu > On 24 Mar 2025, at 11:10 AM, Shengkai Fang wrote: > > Hi, Ammu. > > Thanks for

Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-03-23 Thread Shengkai Fang
Hi, Ammu. Thanks for the improvement, I have assigned it to you. Best, Shengkai Ammu P 于2025年3月24日周一 12:57写道: > Hi Shengkai, > > Thanks for the detailing. That clarified the setup related questions. > However it would be nice to have this captured somewhere in the gateway > documentation so

Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-03-23 Thread Ammu P
Hi Shengkai, Thanks for the detailing. That clarified the setup related questions. However it would be nice to have this captured somewhere in the gateway documentation so that the doc becomes much more user friendly. I have created a ticket[1] with my suggestions on the improvement and I am ha

Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-03-12 Thread Shengkai Fang
Hi Ammu, The SQL Gateway enables clients to specify which cluster to submit jobs to. Here’s my understanding of the workflow: 1. The SQL client reads the configuration files (flink-conf.yaml or config.yaml) located in $FLINK_HOME/conf. The default configuration typically includes the rest.address

Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-03-12 Thread Ammu P
Hi Shengkai, Thanks for responding. It works after setting rest.address. Now the docker file looks like below: services: sql-gateway: image: flink-1.20 ports: - "8083:8083" command: sql-gateway.sh start-foreground -Dsql-gateway.endpoint.rest.address=localhost depends_on:

Re: Question on usage of SQL Gateway with a remote Flink cluster

2025-03-11 Thread Shengkai Fang
Sql client uses the REST API to submit flink jobs. So you should use the option `rest.address` and `rest.port` to expose jobmanager address. Best, Shengkai Ammu P 于2025年3月5日周三 15:53写道: > Hi everyone, > > I am trying to run a SQL script through SQL Client in gateway mode. The > gateway is runnin

Question on usage of SQL Gateway with a remote Flink cluster

2025-03-04 Thread Ammu P
Hi everyone, I am trying to run a SQL script through SQL Client in gateway mode. The gateway is running in a separate container not associated with the Flink cluster. When trying to issue a command from SQL Client locally to the gateway resulted in a connection error something like : WARN o