Re: Pyflink 1.10.0 issue on cluster

Posted by Xingbo Huang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Pyflink-1-10-0-issue-on-cluster-tp36959p36973.html

Hi,
You can use the `set_python_requirements` method to specify your requirement.txt which you can refer to the documentation[1] for details

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/dependency_management.html#python-dependency

Best,
Xingbo

rookieCOder <[hidden email]> 于2020年7月27日周一 下午8:29写道：

Hi,
And I've got another question.
If I use user-defined function in pyflink, which only depends library A. And
what the flink does is using the udf in tables.
Does that mean I only need to install library A on the slaves?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/