THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Authors: Wei Zhong, Dian Fu
Status
Current state: "Accepted"
Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Flink-Python-UDF-Environment-and-Dependency-Management-td33514.html
JIRA: FLINK-14019
...
| Page properties | ||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
| Short Name | Full Name | Syntax | Description |
|---|---|---|---|
-pyfs | --pyFiles | -pyfs <filePaths> | This option already exists but it only appends the file to client side PYTHONPATH currently. Now it will upload the file to cluster and append it to python worker’s PYTHONPATH, which is equivalent to "add_python_file". |
-pyexec | --pyExecutable | -pyexec <pythonInterpreterPath> | This option is equivalent to `TableEnvironment#get_config().set_python_executable()`. |
-pyreq | --pyRequirements | -pyreq <requirementsFile>#<requirementsCachedDir> | This option is equivalent to "set_python_requirements". "#" can be used to as the separator if "requirementsCachedDir" exists. |
-pyarch | --pyArchivepyArchives | -pyarch <archiveFile1>#<extractName>,<archiveFile2>#<extractName> | The option is equivalent to "add_python_archive". "," can be used as the separator for multiple archives and "#" can be used as the separator if "extractName" exists. |
...