This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7c2620f [FLINK-14026][python] Manage the resource of Python worker
properly
add 70c2c16 [FLINK-14019][python][cli] Add commandline options for
managing Python UDF environment and dependencies.
No new revisions were added by this update.
Summary of changes:
docs/ops/cli.md | 80 ++++++++++++++---
docs/ops/cli.zh.md | 63 +++++++++++--
.../apache/flink/client/cli/CliFrontendParser.java | 52 +++++++++--
.../apache/flink/client/cli/ProgramOptions.java | 68 +++++---------
.../flink/client/cli/CliFrontendRunTest.java | 21 +++++
flink-python/pyflink/common/dependency_manager.py | 31 +++++++
.../common/tests/test_dependency_manager.py | 88 ++++++++++--------
flink-python/pyflink/table/table_environment.py | 1 +
flink-python/pyflink/testing/test_case_utils.py | 42 ++++++++-
.../apache/flink/client/python/PythonDriver.java | 2 +-
.../flink/client/python/PythonDriverEnvUtils.java | 48 +++++++++-
.../flink/client/python/PythonDriverOptions.java | 54 +++++++++--
.../python/PythonDriverOptionsParserFactory.java | 100 +++++++++++++++++++--
.../client/python/PythonDriverEnvUtilsTest.java | 39 ++++++--
.../PythonDriverOptionsParserFactoryTest.java | 53 +++++++++++
.../flink/client/python/PythonDriverTest.java | 8 +-
16 files changed, 620 insertions(+), 130 deletions(-)
