Client部分

python.files选项配置的文件会上传BlobServer并且设置以下值
python.internal.files-key-map -> {LinkedHashMap@6558} size =

• python.internal.files-key-map 配置只会设置进CommonPythonBase中

LinkedHashMap key blobKey value fileName

PythonDependencyUtils#configure()
�
Flink SQL编译时如果有PythonUDF会执行到StreamExecPythonCalc
StreamExecPythonCalc和BatchExecPythonCalc继承trait CommonPythonCalc继承CommonPythonBase
�其中CommonPythonBase#getMergedConfig会反射PythonConfigUtil#getMergedConfig

�
�

�
�

附录

python.requirements和python.archives与python.files同理
�

TaskManager部分

Python算子启动BeamPythonFunctionRunner#open()
依赖安装
ProcessPythonEnvironmentManager
�
PythonEnvironmentManagerUtils#pipInstallRequirements
�