Согласно этой странице слияния:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
python udf во Flink 1.11 доступны для использования в функциях 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;
Что мне не хватает?
С уважением,
Джонатан