This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b29af7d [FLINK-17036][metrics][datadog] Support EU data center
add 6f235b0 [FLINK-16666][table][python] Introduce Python dependency
config options
No new revisions were added by this update.
Summary of changes:
docs/_includes/generated/python_configuration.html | 30 +++
flink-python/pyflink/common/dependency_manager.py | 120 ----------
.../common/tests/test_dependency_manager.py | 167 --------------
flink-python/pyflink/java_gateway.py | 2 +
flink-python/pyflink/table/table_config.py | 7 +-
flink-python/pyflink/table/table_environment.py | 37 +++-
.../java/org/apache/flink/python/PythonConfig.java | 50 ++---
.../org/apache/flink/python/PythonOptions.java | 58 +++++
.../env/ProcessPythonEnvironmentManager.java | 6 +-
.../flink/python/env/PythonDependencyInfo.java | 44 ++--
.../flink/python/util/PythonDependencyUtils.java | 245 +++++++++++++++++++++
.../org/apache/flink/python/PythonConfigTest.java | 44 ++--
.../org/apache/flink/python/PythonOptionsTest.java | 68 ++++++
.../env/ProcessPythonEnvironmentManagerTest.java | 15 +-
.../flink/python/env/PythonDependencyInfoTest.java | 48 ++--
.../python/util/PythonDependencyUtilsTest.java | 201 +++++++++++++++++
.../BaseRowPythonScalarFunctionRunnerTest.java | 2 +-
.../scalar/PythonScalarFunctionRunnerTest.java | 4 +-
.../arrow/ArrowPythonScalarFunctionRunnerTest.java | 2 +-
.../BaseRowPythonTableFunctionRunnerTest.java | 2 +-
.../table/PythonTableFunctionRunnerTest.java | 4 +-
.../plan/nodes/common/CommonPythonBase.scala | 29 ++-
.../nodes/physical/batch/BatchExecPythonCalc.scala | 2 +-
.../physical/batch/BatchExecPythonCorrelate.scala | 2 +-
.../physical/stream/StreamExecPythonCalc.scala | 2 +-
.../stream/StreamExecPythonCorrelate.scala | 2 +-
.../flink/table/plan/nodes/CommonPythonBase.scala | 56 ++++-
.../plan/nodes/dataset/DataSetPythonCalc.scala | 2 +-
.../nodes/datastream/DataStreamPythonCalc.scala | 2 +-
.../datastream/DataStreamPythonCorrelate.scala | 2 +-
30 files changed, 839 insertions(+), 416 deletions(-)
delete mode 100644 flink-python/pyflink/common/dependency_manager.py
delete mode 100644 flink-python/pyflink/common/tests/test_dependency_manager.py
create mode 100644
flink-python/src/main/java/org/apache/flink/python/util/PythonDependencyUtils.java
create mode 100644
flink-python/src/test/java/org/apache/flink/python/util/PythonDependencyUtilsTest.java
