在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;
还没有评论,来说两句吧...