apache flink 1.11无法在sql函数ddl中使用python udf

to94eoyn 于 2021-06-21 发布在 Flink

关注(0)|答案(1)|浏览(716)

根据这个合流页面： https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL 在flink1.11中，python自定义项可以与in-sql函数一起使用。
我去了Flink医院： https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sqlClient.html 在终端上尝试此操作，并使用以下参数启动sql-client.sh： $ sql-client.sh embedded --pyExecutable /Users/jonathanfigueroa/opt/anaconda3/bin/python --pyFiles /Users/jonathanfigueroa/Desktop/pyflink/inference/test1.py 然后：

> Create Temporary System Function func1 as 'test1.func1' Language PYTHON;
[INFO] Function has been created.

当我尝试时：

> Select func1(str) From (VALUES ("Name1", "Name2", "Name3"));
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalStateException: Instantiating python function 'test1.func1' failed.

我试过使用： -pyarch,--pyArchives, -pyexec,--pyExecutable, -pyfs,--pyFiles 在每一个组合中 .zip, .py 结果总是一样的。
顺便说一句，我的python文件如下所示：

def func1(s):
    return s;

我有什么遗漏吗？
谨致问候，
乔纳森

python user-defined-functions apache-flink pyflink flink-table-api

来源：https://stackoverflow.com/questions/62822456/apache-flink-1-11-unable-to-use-python-udf-in-sql-function-ddl

1条答案

按热度按时间

qfe3c7zg1#

python udf应该由 pyflink.table.udf ，如下所示：

from pyflink.table.types import DataTypes
from pyflink.table.udf import udf

@udf(input_types=[DataTypes.INT()], result_type=DataTypes.INT())
def add_one(a):
    return a + 1

启动sql客户机时需要加载flink python jar，如下所示：

$ cd $FLINK_HOME/bin
$ ./start-cluster.sh
$ ./sql-client.sh embedded -pyfs xxx.py -j ../opt/flink-python_2.11-1.11.0.jar

此外，您还需要添加 taskmanager.memory.task.off-heap.size: 79mb 至 $FLINK_HOME/conf/flink-conf.yaml 或其他可用于设置配置的文件（例如sql客户端环境文件），否则在执行python udf时会出现错误：

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: The configured Task Off-Heap Memory 0 bytes is less than the least required Python worker Memory 79 mb. The Task Off-Heap Memory can be configured using the configuration key'taskmanager.memory .task.off-heap.size'.

最好的，
世界环境学会

赞(0）回复(0）举报 2021-06-21

我来回答

apache flink 1.11无法在sql函数ddl中使用python udf

1条答案

相关问题

热门标签

最新问答