Hi everyone, In FLIP-58 [1] we have a plan to support Python UDF. As a critical part of python UDF, the environment and dependency management of users' python code has not been fully discussed.
I'd like to start a discussion on "Flink Python UDF Environment and Dependency Management". Here is the design doc I drafted: https://docs.google.com/document/d/1vq5J3TSyhscQXbpRhz-Yd3KCX62PBJeC_a_h3amUvJ4/edit?usp=sharing <https://docs.google.com/document/d/1vq5J3TSyhscQXbpRhz-Yd3KCX62PBJeC_a_h3amUvJ4/edit?usp=sharing> Please take a look, and feedbacks are welcome. Thanks, Wei [1]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-58%3A+Flink+Python+User-Defined+Stateless+Function+for+Table <https://cwiki.apache.org/confluence/display/FLINK/FLIP-58:+Flink+Python+User-Defined+Stateless+Function+for+Table>