Flink 1.12.0 sql客户端查询hive表答案

【问题标题】：Flink 1.12.0 sql client queries hive tableFlink 1.12.0 sql客户端查询hive表
【发布时间】：2020-12-27 17:57:09
【问题描述】：

我正在尝试使用 flink sql 客户端进行配置单元查询并修改 sql-client-defaults.yaml

选择执行类型为batch模式为：

执行：
```
planner: blink

type: batch
```

定义 hive 目录并将 current-catalog 设置为 hive

- name: myhive

  type: hive

  hive-conf-dir: /software/apache-hive-2.3.7-bin/conf/

  default-database: default

然后我启动 sql 客户端：

sql-client.sh embedded

我可以看到 hive 数据库和表。

然后我做下表；

use testdb; ---success
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独立集群后，查询成功。我会问

为什么要启动flink独立集群，我一直以为是本地模式运行（我有sql客户端sql-client.sh embedded）
我可以在 yarn 集群上使用 sql 客户端吗？

【问题讨论】：

标签： apache-flink

【解决方案1】：

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

SQL 执行器嵌入在 SQL 客户端中的位置。但是 Flink 集群仍然在 SQL 客户端的外部。有关更多信息，请参阅FLIP-24。

为了将 SQL 客户端连接到非本地集群，SQL 客户端 YAML 有一个部署部分。您可以在那里使用常规的 flink 运行选项并进行配置，例如你的 YARN 会话集群。另见Flink SQL Client connect to non local cluster。

【讨论】：