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

Posted to commits@flink.apache.org by di...@apache.org on 2021/09/09 12:25:24 UTC

[flink] branch master updated (60046b1 -> 0b4855f)

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 60046b1  [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API
     add 7a1b2b3  [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode
     add 0b4855f  [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode

No new revisions were added by this update.

Summary of changes:
 .../datastream/stream_execution_environment.py     | 24 ++++++++++--
 .../tests/test_stream_execution_environment.py     | 17 ++++-----
 .../fn_execution/beam/beam_worker_pool_service.py  |  6 +--
 flink-python/pyflink/table/table_environment.py    | 23 +++++++++--
 .../pyflink/table/tests/test_dependency.py         | 44 +++++++++++-----------
 flink-python/pyflink/testing/test_case_utils.py    |  8 ++--
 6 files changed, 76 insertions(+), 46 deletions(-)