Flink应用开发系列（六十五）Table SQL开发之添加依赖包

在flink环境中，我们有时候由于不能重启整个flink集群，但是由于job作业的原因需要把对应的jar包添加到flink的执行环境中去，怎么办呢？

这里在flink table sql 官方里面提供了jar相关的函数，我们可以直接使用相关的函数把这些jar包放到flink的执行环境中去。下面举例

1）添加jar包

这里我们可以添加一个本地的jar包也可以添加一个远程文件系统中的jar包，对应的sql语句如下：

#添加本地jar包
add jar '/mnt/Flink-App-1.0-SNAPSHOT.jar'

#添加远程hdfs上的jar包
add jar 'hdfs://192.168.31.218:8020/jars/Flink-App-.jar'

2）查看所有的jar包

查看所有的jar包比较简单，使用的sql语句如下：

show jars

3）移除不要的jar包

移除不要的jar包的话，也比较简单，和add对应即可，使用的sql语句如下：

remove jar '/mnt/Flink-App-1.0-SNAPSHOT.jar'

备注：

1、只能在sql-client.sh执行环境中使用remove jar，不能在代码及其他地方使用remove jar；