本文为您介绍如何管理Flink全托管自定义函数(UDF),包括注册、更新和删除。
注册UDF
如果您的SQL需要使用UDF,您需要先注册您的UDF,才能在SQL中使用。
- 登录实时计算控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击SQL编辑器。
- 单击 Artifacts页签。
- 在页面左上角,单击
图标。
- 上传UDF JAR文件。

您可以通过以下任何一种方式上传UDF JAR文件:
- 上传文件:单击选择文件后,选择您的目标UDF JAR文件。
- 外部URL:输入外部URL地址。
说明 您的UDF JAR文件会被上传到您选择的OSS Bucket中的artifacts目录下。此外,开发控制台会解析您UDF JAR文件中是否使用了Flink UDF、UDAF和UDTF接口的类,并自动提取类名,填充到Function Name字段中。
- 单击确认。
在SQL编辑器页面左侧Artifacts列表,您可以看到所有注册成功的UDF。
更新UDF JAR
如果您的UDF JAR中,新增了UDF或已注册了UDF的类代码变更,您可以按照以下步骤更新UDF JAR。
- 登录实时计算控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击SQL编辑器。
- 单击 Artifacts页签。
- 在UDF JARs列表中,鼠标悬停在目标JAR名称上,单击
。
- 上传JAR文件。

您可以通过以下任何一种方式上传JAR文件:
- 上传文件:单击选择文件后,选择您的目标UDF JAR文件。
- 外部URL:输入外部URL地址。
注意
- 您上传的新UDF JAR中,必须包含当前已经注册UDF的所有类,不能出现某个已注册UDF的类消失的情况。
- 只有重启作业或提交新作业时,才会使用新JAR文件中的代码。如果您引用该UDF JAR的作业正在运行,则依然会使用旧JAR文件。
- 单击修改。
删除UDF JAR
如果您的UDF JAR不再使用,您可以按照以下步骤删除UDF。
- 登录实时计算控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,单击SQL编辑器。
- 单击 Artifacts页签。
- 在UDF JAR列表中,鼠标悬停在目标JAR名称上,单击
图标。
说明 在删除JAR文件前,请确定其注册的UDF没有被作业或SQL文件引用。
- 选中删除关联的JAR。
如果您要删除该JAR文件,则需要删除该JAR注册的所有UDF,避免有脏数据残留。
- 单击确认。
在文档使用中是否遇到以下问题
更多建议
匿名提交