Flink 1.12.0 sql客户端查询单元表

Question

我正在尝试使用flink sql客户端执行单元查询，并修改sql defaults.yaml

1. 选择到batch模式的执行类型如下： 处决： 计划者:眨眼类型:批次
2. 定义单元目录并将当前目录设置为hive。 目录：

• 名称: myhive类型: hive hive-conf-dir: /conf/apache-hive-2.3.7 bin/conf/ default-database: default

然后，我用以下方式启动sql客户端：

sql-client.sh embedded

我能看到蜂巢数据库和表格。

然后我做下面的表格；

1. use testdb; ---success
2. select * from t1 limit 10; ---fail

第二步失败，例外情况如下：

Flink SQL> select * from t1;
2020-12-21 11:33:27,755 WARN  org.apache.hadoop.hive.conf.HiveConf                         [] - HiveConf of name hive.metastore.local does not exist
2020-12-21 11:33:28,599 INFO  org.apache.hadoop.mapred.FileInputFormat                     [] - Total input paths to process : 1
[ERROR] Could not execute SQL statement. Reason:
java.net.ConnectException: Connection refused

我会问如何修复connection refused异常

谢谢。

更新：

启动flink独立集群之后，查询就成功了。我会问

1. 为什么我必须启动flink独立集群，我认为它在本地模式下运行(我有带有SQLclient.shembedded的client.sh)
2. 我可以在纱线集群上使用sql客户端吗？

Answer 1

sql客户端依赖于能够向集群提交查询。“嵌入式”指的是这种架构，

​

​

其中SQL执行器嵌入到SQL客户端中。但是Flink集群仍然位于SQL客户端的外部。有关此问题的更多信息，请参见翻转-24。

要将SQL客户端连接到非本地群集，SQL客户端YAML有一个部署部分。您可以在那里使用常规的flink运行选项，并配置您的纱线会话集群。另见Flink SQL客户端连接到非本地群集。