安装机器:192.168.12.126-128

path:/data/flink

192.168.12.126flink01

master

worker

192.168.12.127flink02worker
192.168.12.128flink03worker

flink-web-ui:http://192.168.12.126:8083/#/overview

启动sql-gateway:

#这里如果不指定sql-gateway.endpoint.rest.address会报错,无法启动;如果不指定rest.bind-port会使用config.yaml中rest.bind-port范围随机的一个端口

./sql-gateway.sh start -Dsql-gateway.endpoint.rest.address=flink01 -Drest.bind-port=8085

通过sql-client链接sql-gateway:

./sql-client.sh gateway --endpoint http://flink01:8084

更多推荐