CDH上Flink执行sql-client命令提示[ERROR] Could not execute SQL statement. Reason: java.net.ConnectException: 拒绝连接

在cdh6.3.2上执行sql-client的命令,提示:

[ERROR] Could not execute SQL statement. Reason:
java.net.ConnectException: 拒绝连接

这可能是由于以下原因:

  • 您没有启动flink集群,或者flink集群不可用。您可以检查flink集群的状态,或者尝试重新启动flink集群。
  • 您没有正确地配置flink sql-client的环境,或者您的配置文件有误。您可以检查您的sql-client-defaults.yaml文件,或者参考官方文档来设置flink sql-client的环境。
  • 您的网络有问题,或者您的防火墙阻止了flink sql-client的连接。您可以检查您的网络连接,或者允许flink sql-client通过防火墙。

原来是需要启动本地集群:

./start-cluster.sh
cd /opt/cloudera/parcels/FLINK-1.14.4-BIN-SCALA_2.12/lib/flink/bin

然后再次启动sql客户端即可执行成功。

关注公众号“大模型全栈程序员”回复“小程序”获取1000个小程序打包源码。更多免费资源在http://www.gitweixin.com/?p=2627

发表评论

邮箱地址不会被公开。 必填项已用*标注