You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by he...@apache.org on 2020/08/14 02:25:57 UTC

[flink] branch master updated (d17993f -> 62b20b0)

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 d17993f  [FLINK-18719][runtime] Introduce new ActiveResourceManager.
     add 62b20b0  [FLINK-18878][python] Support dependency management for Python StreamExecutionEnvironment. (#13136)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/data_stream.py     |  21 ++-
 .../datastream/stream_execution_environment.py     | 191 ++++++++++++++++++-
 .../tests/test_stream_execution_environment.py     | 209 +++++++++++++++++++++
 .../java/org/apache/flink/python/PythonConfig.java |  10 +
 .../apache/flink/python/util/PythonConfigUtil.java |  91 ++++++++-
 .../python/AbstractPythonFunctionOperator.java     |  16 +-
 .../flink/python/util/PythonConfigUtilTest.java    |   2 +-
 7 files changed, 520 insertions(+), 20 deletions(-)