MAPREDUCE服务 MRS-配置FlinkServer作业中使用UDF:上传UDF至FlinkServer

时间:2024-11-28 01:44:36

上传UDF至FlinkServer

  1. 准备UDF jar文件,大小不能超过200MB。
  2. 访问Flink WebUI,请参考访问FlinkServer WebUI界面
  3. 单击“UDF管理”进入UDF管理页面。
  4. 单击“添加UDF”,在“本地Jar文件”参数后选择并上传本地已准备好的UDF jar文件。
  5. 填写UDF名称以及描述信息后,单击“确定”。

    • “UDF名称”最多可添加10项,“名称”可自定义,“类名”需与上传的UDF jar文件中UDF函数全限定类名一一对应。
    • 上传UDF jar文件后,服务器默认保留5分钟,5分钟内单击确定则完成UDF创建,超时后单击确定则创建UDF失败并弹出错误提示:本地UDF文件路径有误。

  6. 在UDF列表中,可查看当前应用内所有的UDF信息。可在对应UDF信息的“操作”列编辑或删除UDF信息(只能删除未被使用的UDF项)。
  7. (可选)如果需要立即运行或开发作业,可在“作业管理”进行相关作业配置,可参考如何创建FlinkServer作业
support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_24211.html