Zeppelin 支持加载UDF jar的,可以参考下面的代码,不过架构上可能与你们的原有架构会有所差别
https://www.yuque.com/jeffzhangjianfeng/gldg8w/dthfu2#8iONE
https://github.com/apache/zeppelin/blob/master/flink/interpreter/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala#L469
chenxyz 于2021年3月12日周五 上午9:42写道:
> 目前这种方法不可
目前这种方法不可行,在公司的平台化系统里提交flink任务,自己能掌控的只有代码这块。
在 2021-03-11 16:39:24,"silence" 写道:
>启动时通过-C加到classpath里试试
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/
请user-zh 不要再发邮件了
--
发件人:silence
发送时间:2021年3月11日(星期四) 16:39
收件人:user-zh
主 题:Re: flink sql如何从远程加载jar包中的udf
启动时通过-C加到classpath里试试
--
Sent from: http://apache-flink.147419.n8.nabble.com/
启动时通过-C加到classpath里试试
--
Sent from: http://apache-flink.147419.n8.nabble.com/
1.10应该是registerFunction吧,当前jar包中没有这个类(这个类在远程jar包中),这种方法没办法实例化TableFunction。
> 2021年3月11日 上午11:21,HunterXHunter <1356469...@qq.com> 写道:
>
> 通过 createTemporarySystemFunction 试试看呢
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
通过 createTemporarySystemFunction 试试看呢
--
Sent from: http://apache-flink.147419.n8.nabble.com/
我们将开发的udf放在远程服务器,需要动态地加载jar包。Flink版本1.10,代码如下
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment exeEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings envSet = EnvironmentSettings
.newInstance()
.useBlin