[flink] branch master updated (b29af7d -> 6f235b0)

[di...@apache.org]

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