1、手把手教你学会使用 FlinkSQL客户端

目录

1、FlinkSQL客户端的功能

2、FlinkSQL客户端启动参数配置

2.1 基本语法

2.2 相关参数([MODE])：

2.3 相关参数(embedded [OPTIONS])：

3、启动Flink的sql-client

3.1 启动时使用初始化脚本

3.2 启动时指定依赖的jar包

3.3 基于yarn-session模式 启动

4、FlinkSQL客户端中的常用配置

4.1 查询结果显示模式配置

4.2 并行度配置

4.3 指定状态的TTL(状态空闲时间)

4.4 指定执行模式

4.5 指定自定义JobName

---

1、FlinkSQL客户端的功能

        提供一个客户端，不需要写一行java或scala代码，只需通过写SQL的方式就能向Flink集群提交流式计算任务。

---

2、FlinkSQL客户端启动参数配置

2.1 基本语法

./sql-client [MODE] [OPTIONS]

2.2 相关参数([MODE])：

    MODE = embedded 
        默认选项 表示从本地机器提交Flink作业
    MODE = gateway
        表示通过SQL网关进行提交

2.3 相关参数(embedded [OPTIONS])：

    -f,--file