CATALOG FUNCTION不会覆盖
这个现象是没有问题的。
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
@flink.apache.org
主题： 回复: 回复：回复: flink 自定义udf注册后不能使用
你这样创建试一下，或者换个名字试试
CREATE TEMPORARY SYSTEM FUNCTION imei_encrypt AS
'com.intsig.flink.udf.IMEIEncrypt' LANGUAGE JAVA;
我刚才创建了一个 UpperCase的function，也是一样的错误，用TEMPORARY SYSTEM覆盖系统的函数(有可能存在)后，就可以了，换个字也可以
发件人: 奔跑的小飞袁
发送时间: 2020年10月
@flink.apache.org
主题： 回复: 回复：回复: flink 自定义udf注册后不能使用
你这样创建试一下，或者换个名字试试
CREATE TEMPORARY SYSTEM FUNCTION imei_encrypt AS
'com.intsig.flink.udf.IMEIEncrypt' LANGUAGE JAVA;
我刚才创建了一个 UpperCase的function，也是一样的错误，用TEMPORARY SYSTEM覆盖系统的函数(有可能存在)后，就可以了，换个字也可以
发件人: 奔跑的小飞袁
发送时间: 2020年10月
是的，同款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
@flink.apache.org
主题: Re: 回复：回复: flink 自定义udf注册后不能使用
是的，是我传参有问题
--
Sent from: http://apache-flink.147419.n8.nabble.com/
是的，是我传参有问题
--
Sent from: http://apache-flink.147419.n8.nabble.com/
是的，我这个函数只需要一个参数
--
Sent from: http://apache-flink.147419.n8.nabble.com/
你好，没看错的话，只有一个参？
--
发件人：奔跑的小飞袁
发送时间：2020年10月16日(星期五) 14:18
收件人：user-zh
主 题：Re: 回复: flink 自定义udf注册后不能使用
完整的sql执行文件
SET stream.enableCheckpointing=1000*60;
SET stream.setParallelism=4;
CREATE FUNCTION imei_encrypt
完整的sql执行文件
SET stream.enableCheckpointing=1000*60;
SET stream.setParallelism=4;
CREATE FUNCTION imei_encrypt AS 'com.intsig.flink.udf.IMEIEncrypt' LANGUAGE
JAVA;
-- Kafka cdbp zdao source 表
create TABLE cloud_behavior_source(
operation VARCHAR,
operation_channel VARCHAR,
`time`
这是我的udf声明
CREATE FUNCTION imei_encrypt AS 'com.intsig.flink.udf.IMEIEncrypt' LANGUAGE
JAVA;
以下是udf实现
public class IMEIEncrypt extends ScalarFunction {
public String eval(String column_type,String value) {
EncryptUtils encryptUtils = new EncryptUtils();
return
Hi, 从日志上看 是说 匹配不到 imei_encrypt的UDF，有可能是sql里传的字段和imei_encrypt的参数不匹配，
能看下你的具体代码和udf的声明吗
发件人: 奔跑的小飞袁
发送时间: 2020年10月16日 3:30
收件人: user-zh@flink.apache.org
主题: flink 自定义udf注册后不能使用
hello
我在使用flinkSQL注册udf时，发生了以下错误，这是我定义有问题还是flink的bug
11 matches
Mail list logo
