[Bug] [python UDF] An error occurs when registering PythonFlinkUDF in a FlinkSQL task.

[YANGZE98920]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

我在使用python flink udf 时报错 无法找到根因，需要帮助

What you expected to happen

我在使用python flink udf 时报错 无法找到根因，需要帮助

How to reproduce

帮帮忙排查一下问题在哪

Anything else

Version

1.0.1

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Hello @YANGZE98920, this issue is about UDF, so I assign it to @gaoyan1998 and @zackyoungh. If you have any questions, you can comment and reply.

你好 @YANGZE98920, 这个 issue 是关于 UDF 的，所以我把它分配给了 @gaoyan1998 和 @zackyoungh。如有任何问题，可以评论回复。

[Zzm0809]

提供复现步骤

[YANGZE98920]

上述截图即是复现我按照步骤重新截图
第一步：写了一个udf的简单例子

第二步：注册udf函数 select 使用函数

第三步：配置参数设置

第四步：dinky 运行环境检查


第五步：flink on K8s seesion环境集群检查：

第六步：查询该任务报错

[Zzm0809]

请按照模版 python udf 修改

[YANGZE98920]

mo'ba模板上也是这样的呀

[YANGZE98920]

yi'j已按照python udf 模板修改 修改后还是报同样错误

[YANGZE98920]

跟这个地方相关嘛

[YANGZE98920]

大佬帮忙看看 搞定之后写成最佳实践文档 为社区做出贡献

[github-actions]

Hello @, this issue has not been active for more than 30 days. This issue will be closed in 7 days if there is no response. If you have any questions, you can comment and reply.

你好 @, 这个 issue 30 天内没有活跃，7 天后将关闭，如需回复，可以评论回复。