Re: Re: flink sql如何从远程加载jar包中的udf

2021-03-11 文章 Jeff Zhang
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写道: > 目前这种方法不可

Re:Re: flink sql如何从远程加载jar包中的udf

2021-03-11 文章 chenxyz
目前这种方法不可行,在公司的平台化系统里提交flink任务,自己能掌控的只有代码这块。 在 2021-03-11 16:39:24,"silence" 写道: >启动时通过-C加到classpath里试试 > > > >-- >Sent from: http://apache-flink.147419.n8.nabble.com/

回复:flink sql如何从远程加载jar包中的udf

2021-03-11 文章 邓从宝
请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/

Re: flink sql如何从远程加载jar包中的udf

2021-03-11 文章 silence
启动时通过-C加到classpath里试试 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink sql如何从远程加载jar包中的udf

2021-03-10 文章 chenxyz
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/

Re: flink sql如何从远程加载jar包中的udf

2021-03-10 文章 HunterXHunter
通过 createTemporarySystemFunction 试试看呢 -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink sql如何从远程加载jar包中的udf

2021-03-10 文章 chenxyz
我们将开发的udf放在远程服务器,需要动态地加载jar包。Flink版本1.10,代码如下 public static void main(String[] args) throws Exception { StreamExecutionEnvironment exeEnv = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings envSet = EnvironmentSettings .newInstance() .useBlin