Hi, 当前可以理解Flink注册UDF有三种类型: - TEMPORARY SYSTEM FUNCTION - TEMPORARY CATALOG FUNCTION - CATALOG FUNCTION
加上内置的SYSTEM FUNCTION 可以认为一共有四种,他们的解析顺序为: 1. TEMPORARY SYSTEM FUNCTION 2. SYSTEM FUNCTION 3. TEMPORARY CATALOG FUNCTION 4. CATALOG FUNCTION 所以你观察到TEMPORARY SYSTEM FUNCTION会覆盖内置函数,但是TEMPORARY CATALOG FUNCTION不会覆盖 这个现象是没有问题的。 amen...@163.com <amen...@163.com> 于2020年10月16日周五 下午3:46写道: > 是的,同款TEMPORARY FUNCTION错误,但是使用SYSTEMTEMPORARY就没有问题,不知是否是flink的bug > > best, > amenhub > > 发件人: 史 正超 > 发送时间: 2020-10-16 15:26 > 收件人: user-zh@flink.apache.org > 主题: 回复: 回复:回复: flink 自定义udf注册后不能使用 > 你这样创建试一下,或者换个名字试试 > > CREATE TEMPORARY SYSTEM FUNCTION imei_encrypt AS > 'com.intsig.flink.udf.IMEIEncrypt' LANGUAGE JAVA; > > 我刚才创建了一个 UpperCase的function,也是一样的错误,用TEMPORARY > SYSTEM覆盖系统的函数(有可能存在)后,就可以了,换个字也可以 > > ________________________________ > 发件人: 奔跑的小飞袁 <s_hongli...@126.com> > 发送时间: 2020年10月16日 6:47 > 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> > 主题: Re: 回复:回复: flink 自定义udf注册后不能使用 > > 是的,是我传参有问题 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ > -- Best, Benchao Li